See
<https://ci-beam.apache.org/job/beam_Python_LoadTests_FnApiRunner_Microbenchmark/1460/display/redirect>
Changes:
------------------------------------------
[...truncated 147.85 KB...]
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk0/Read)+(ref_AppliedPTransform_stage5_map1_152))+(stage5_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk1/Read)+(ref_AppliedPTransform_stage5_map2_154))+(stage5_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk2/Read)+(ref_AppliedPTransform_stage5_map3_156))+(stage5_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk3/Read)+(ref_AppliedPTransform_stage5_map4_158))+(stage5_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage6-Impulse_165)+(ref_AppliedPTransform_start_stage6-FlatMap-lambda-at-core-py-3229-_166))+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-AddRandomKeys_169))+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_171))+(start_stage6/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage6/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_173))+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-RemoveRandomKeys_174))+(ref_AppliedPTransform_start_stage6-Map-decode-_175))+(gbk_start_stage6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage6/Read)+(ref_AppliedPTransform_stage6_map0_177))+(stage6_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk0/Read)+(ref_AppliedPTransform_stage6_map1_179))+(stage6_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk1/Read)+(ref_AppliedPTransform_stage6_map2_181))+(stage6_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk2/Read)+(ref_AppliedPTransform_stage6_map3_183))+(stage6_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk3/Read)+(ref_AppliedPTransform_stage6_map4_185))+(stage6_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk4/Read)+(ref_AppliedPTransform_stage6_map5_187))+(stage6_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk5/Read)+(ref_AppliedPTransform_stage6_map6_189))+(stage6_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage0-Impulse_3)+(ref_AppliedPTransform_start_stage0-FlatMap-lambda-at-core-py-3229-_4))+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-AddRandomKeys_7))+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_9))+(start_stage0/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage0/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_11))+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-RemoveRandomKeys_12))+(ref_AppliedPTransform_start_stage0-Map-decode-_13))+(gbk_start_stage0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage0/Read)+(ref_AppliedPTransform_stage0_map0_15))+(stage0_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk0/Read)+(ref_AppliedPTransform_stage0_map1_17))+(stage0_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk1/Read)+(ref_AppliedPTransform_stage0_map2_19))+(stage0_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage2-Impulse_57)+(ref_AppliedPTransform_start_stage2-FlatMap-lambda-at-core-py-3229-_58))+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-AddRandomKeys_61))+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_63))+(start_stage2/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage2/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_65))+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-RemoveRandomKeys_66))+(ref_AppliedPTransform_start_stage2-Map-decode-_67))+(gbk_start_stage2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage2/Read)+(ref_AppliedPTransform_stage2_map0_69))+(stage2_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk0/Read)+(ref_AppliedPTransform_stage2_map1_71))+(stage2_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk2/Read)+(ref_AppliedPTransform_stage0_map3_21))+(stage0_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage3-Impulse_84)+(ref_AppliedPTransform_start_stage3-FlatMap-lambda-at-core-py-3229-_85))+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-AddRandomKeys_88))+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_90))+(start_stage3/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage3/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_92))+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-RemoveRandomKeys_93))+(ref_AppliedPTransform_start_stage3-Map-decode-_94))+(gbk_start_stage3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage3/Read)+(ref_AppliedPTransform_stage3_map0_96))+(stage3_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk0/Read)+(ref_AppliedPTransform_stage3_map1_98))+(stage3_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk1/Read)+(ref_AppliedPTransform_stage3_map2_100))+(stage3_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk2/Read)+(ref_AppliedPTransform_stage3_map3_102))+(stage3_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk3/Read)+(ref_AppliedPTransform_stage3_map4_104))+(stage3_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk4/Read)+(ref_AppliedPTransform_stage3_map5_106))+(stage3_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage1-Impulse_30)+(ref_AppliedPTransform_start_stage1-FlatMap-lambda-at-core-py-3229-_31))+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-AddRandomKeys_34))+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_36))+(start_stage1/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage1/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_38))+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-RemoveRandomKeys_39))+(ref_AppliedPTransform_start_stage1-Map-decode-_40))+(gbk_start_stage1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage1/Read)+(ref_AppliedPTransform_stage1_map0_42))+(stage1_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk0/Read)+(ref_AppliedPTransform_stage1_map1_44))+(stage1_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk1/Read)+(ref_AppliedPTransform_stage1_map2_46))+(stage1_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk2/Read)+(ref_AppliedPTransform_stage1_map3_48))+(stage1_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk3/Read)+(ref_AppliedPTransform_stage1_map4_50))+(stage1_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk4/Read)+(ref_AppliedPTransform_stage1_map5_52))+(stage1_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk5/Read)+(ref_AppliedPTransform_stage1_map6_54))+(stage1_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk4/Read)+(ref_AppliedPTransform_stage5_map5_160))+(stage5_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage1_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk3/Read)+(ref_AppliedPTransform_stage0_map4_23))+(stage0_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk4/Read)+(ref_AppliedPTransform_stage0_map5_25))+(stage0_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk5/Read)+(ref_AppliedPTransform_stage0_map6_27))+(stage0_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage0_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk5/Read)+(ref_AppliedPTransform_stage3_map6_108))+(stage3_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage4_gbk5/Read)+(ref_AppliedPTransform_stage4_map6_135))+(stage4_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk5/Read)+(ref_AppliedPTransform_stage5_map6_162))+(stage5_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk1/Read)+(ref_AppliedPTransform_stage2_map2_73))+(stage2_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk2/Read)+(ref_AppliedPTransform_stage2_map3_75))+(stage2_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk3/Read)+(ref_AppliedPTransform_stage2_map4_77))+(stage2_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk4/Read)+(ref_AppliedPTransform_stage2_map5_79))+(stage2_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk5/Read)+(ref_AppliedPTransform_stage2_map6_81))+(stage2_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage2_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage3_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage5_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage4_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage6_gbk6/Read
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.7 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.38.0.dev
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function annotate_downstream_side_inputs at 0x7f3106d2f680>
====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function fix_side_input_pcoll_coders at 0x7f3106d2f7a0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function pack_combiners at 0x7f3106d2fcb0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f3106d2fd40> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_sdf at 0x7f3106d2fef0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_gbk at 0x7f3106d2ff80> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sink_flattens at 0x7f3106d290e0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function greedily_fuse at 0x7f3106d29170> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function read_to_impulse at 0x7f3106d29200> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function impulse_to_input at 0x7f3106d29290> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sort_stages at 0x7f3106d294d0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function setup_timer_mapping at 0x7f3106d29440> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function populate_data_channel_coders at 0x7f3106d29560> ====================
INFO:apache_beam.runners.****.statecache:Creating state cache with size 100
INFO:apache_beam.runners.portability.fn_api_runner.****_handlers:Created Worker
handler
<apache_beam.runners.portability.fn_api_runner.****_handlers.EmbeddedWorkerHandler
object at 0x7f3105bd3850> for environment
ref_Environment_default_environment_1 (beam:env:embedded_python:v1, b'')
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage1-Impulse_30)+(ref_AppliedPTransform_start_stage1-FlatMap-lambda-at-core-py-3229-_31))+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-AddRandomKeys_34))+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_36))+(start_stage1/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage1/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_38))+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-RemoveRandomKeys_39))+(ref_AppliedPTransform_start_stage1-Map-decode-_40))+(gbk_start_stage1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage1/Read)+(ref_AppliedPTransform_stage1_map0_42))+(stage1_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk0/Read)+(ref_AppliedPTransform_stage1_map1_44))+(stage1_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk1/Read)+(ref_AppliedPTransform_stage1_map2_46))+(stage1_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk2/Read)+(ref_AppliedPTransform_stage1_map3_48))+(stage1_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk3/Read)+(ref_AppliedPTransform_stage1_map4_50))+(stage1_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage0-Impulse_3)+(ref_AppliedPTransform_start_stage0-FlatMap-lambda-at-core-py-3229-_4))+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-AddRandomKeys_7))+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_9))+(start_stage0/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage0/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_11))+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-RemoveRandomKeys_12))+(ref_AppliedPTransform_start_stage0-Map-decode-_13))+(gbk_start_stage0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage0/Read)+(ref_AppliedPTransform_stage0_map0_15))+(stage0_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk0/Read)+(ref_AppliedPTransform_stage0_map1_17))+(stage0_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk1/Read)+(ref_AppliedPTransform_stage0_map2_19))+(stage0_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk2/Read)+(ref_AppliedPTransform_stage0_map3_21))+(stage0_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk3/Read)+(ref_AppliedPTransform_stage0_map4_23))+(stage0_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk4/Read)+(ref_AppliedPTransform_stage1_map5_52))+(stage1_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk5/Read)+(ref_AppliedPTransform_stage1_map6_54))+(stage1_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage3-Impulse_84)+(ref_AppliedPTransform_start_stage3-FlatMap-lambda-at-core-py-3229-_85))+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-AddRandomKeys_88))+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_90))+(start_stage3/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage3/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_92))+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-RemoveRandomKeys_93))+(ref_AppliedPTransform_start_stage3-Map-decode-_94))+(gbk_start_stage3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage3/Read)+(ref_AppliedPTransform_stage3_map0_96))+(stage3_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk0/Read)+(ref_AppliedPTransform_stage3_map1_98))+(stage3_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk1/Read)+(ref_AppliedPTransform_stage3_map2_100))+(stage3_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk2/Read)+(ref_AppliedPTransform_stage3_map3_102))+(stage3_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk3/Read)+(ref_AppliedPTransform_stage3_map4_104))+(stage3_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk4/Read)+(ref_AppliedPTransform_stage3_map5_106))+(stage3_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage5-Impulse_138)+(ref_AppliedPTransform_start_stage5-FlatMap-lambda-at-core-py-3229-_139))+(ref_AppliedPTransform_start_stage5-MaybeReshuffle-Reshuffle-AddRandomKeys_142))+(ref_AppliedPTransform_start_stage5-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_144))+(start_stage5/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage5/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage5-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_146))+(ref_AppliedPTransform_start_stage5-MaybeReshuffle-Reshuffle-RemoveRandomKeys_147))+(ref_AppliedPTransform_start_stage5-Map-decode-_148))+(gbk_start_stage5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage5/Read)+(ref_AppliedPTransform_stage5_map0_150))+(stage5_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk0/Read)+(ref_AppliedPTransform_stage5_map1_152))+(stage5_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk1/Read)+(ref_AppliedPTransform_stage5_map2_154))+(stage5_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk2/Read)+(ref_AppliedPTransform_stage5_map3_156))+(stage5_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk3/Read)+(ref_AppliedPTransform_stage5_map4_158))+(stage5_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk4/Read)+(ref_AppliedPTransform_stage5_map5_160))+(stage5_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk5/Read)+(ref_AppliedPTransform_stage5_map6_162))+(stage5_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage5_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage4-Impulse_111)+(ref_AppliedPTransform_start_stage4-FlatMap-lambda-at-core-py-3229-_112))+(ref_AppliedPTransform_start_stage4-MaybeReshuffle-Reshuffle-AddRandomKeys_115))+(ref_AppliedPTransform_start_stage4-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_117))+(start_stage4/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage4/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage4-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_119))+(ref_AppliedPTransform_start_stage4-MaybeReshuffle-Reshuffle-RemoveRandomKeys_120))+(ref_AppliedPTransform_start_stage4-Map-decode-_121))+(gbk_start_stage4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage4/Read)+(ref_AppliedPTransform_stage4_map0_123))+(stage4_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage6-Impulse_165)+(ref_AppliedPTransform_start_stage6-FlatMap-lambda-at-core-py-3229-_166))+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-AddRandomKeys_169))+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_171))+(start_stage6/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage6/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_173))+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-RemoveRandomKeys_174))+(ref_AppliedPTransform_start_stage6-Map-decode-_175))+(gbk_start_stage6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage6/Read)+(ref_AppliedPTransform_stage6_map0_177))+(stage6_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk0/Read)+(ref_AppliedPTransform_stage6_map1_179))+(stage6_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk1/Read)+(ref_AppliedPTransform_stage6_map2_181))+(stage6_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk2/Read)+(ref_AppliedPTransform_stage6_map3_183))+(stage6_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk3/Read)+(ref_AppliedPTransform_stage6_map4_185))+(stage6_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk4/Read)+(ref_AppliedPTransform_stage6_map5_187))+(stage6_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk5/Read)+(ref_AppliedPTransform_stage6_map6_189))+(stage6_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage6_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage4_gbk0/Read)+(ref_AppliedPTransform_stage4_map1_125))+(stage4_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage4_gbk1/Read)+(ref_AppliedPTransform_stage4_map2_127))+(stage4_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk5/Read)+(ref_AppliedPTransform_stage3_map6_108))+(stage3_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage2-Impulse_57)+(ref_AppliedPTransform_start_stage2-FlatMap-lambda-at-core-py-3229-_58))+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-AddRandomKeys_61))+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_63))+(start_stage2/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage2/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_65))+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-RemoveRandomKeys_66))+(ref_AppliedPTransform_start_stage2-Map-decode-_67))+(gbk_start_stage2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage2/Read)+(ref_AppliedPTransform_stage2_map0_69))+(stage2_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk0/Read)+(ref_AppliedPTransform_stage2_map1_71))+(stage2_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk1/Read)+(ref_AppliedPTransform_stage2_map2_73))+(stage2_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk2/Read)+(ref_AppliedPTransform_stage2_map3_75))+(stage2_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk3/Read)+(ref_AppliedPTransform_stage2_map4_77))+(stage2_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage4_gbk2/Read)+(ref_AppliedPTransform_stage4_map3_129))+(stage4_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage4_gbk3/Read)+(ref_AppliedPTransform_stage4_map4_131))+(stage4_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage4_gbk4/Read)+(ref_AppliedPTransform_stage4_map5_133))+(stage4_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage4_gbk5/Read)+(ref_AppliedPTransform_stage4_map6_135))+(stage4_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk4/Read)+(ref_AppliedPTransform_stage2_map5_79))+(stage2_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk5/Read)+(ref_AppliedPTransform_stage2_map6_81))+(stage2_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk4/Read)+(ref_AppliedPTransform_stage0_map5_25))+(stage0_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage1_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk5/Read)+(ref_AppliedPTransform_stage0_map6_27))+(stage0_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage2_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage0_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage4_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage3_gbk6/Read
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.7 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.7_sdk:2.38.0.dev
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function annotate_downstream_side_inputs at 0x7f3106d2f680>
====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function fix_side_input_pcoll_coders at 0x7f3106d2f7a0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function pack_combiners at 0x7f3106d2fcb0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f3106d2fd40> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_sdf at 0x7f3106d2fef0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_gbk at 0x7f3106d2ff80> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sink_flattens at 0x7f3106d290e0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function greedily_fuse at 0x7f3106d29170> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function read_to_impulse at 0x7f3106d29200> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function impulse_to_input at 0x7f3106d29290> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sort_stages at 0x7f3106d294d0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function setup_timer_mapping at 0x7f3106d29440> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function populate_data_channel_coders at 0x7f3106d29560> ====================
INFO:apache_beam.runners.****.statecache:Creating state cache with size 100
INFO:apache_beam.runners.portability.fn_api_runner.****_handlers:Created Worker
handler
<apache_beam.runners.portability.fn_api_runner.****_handlers.EmbeddedWorkerHandler
object at 0x7f31067620d0> for environment
ref_Environment_default_environment_1 (beam:env:embedded_python:v1, b'')
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage4-Impulse_111)+(ref_AppliedPTransform_start_stage4-FlatMap-lambda-at-core-py-3229-_112))+(ref_AppliedPTransform_start_stage4-MaybeReshuffle-Reshuffle-AddRandomKeys_115))+(ref_AppliedPTransform_start_stage4-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_117))+(start_stage4/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage4/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage4-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_119))+(ref_AppliedPTransform_start_stage4-MaybeReshuffle-Reshuffle-RemoveRandomKeys_120))+(ref_AppliedPTransform_start_stage4-Map-decode-_121))+(gbk_start_stage4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage4/Read)+(ref_AppliedPTransform_stage4_map0_123))+(stage4_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage4_gbk0/Read)+(ref_AppliedPTransform_stage4_map1_125))+(stage4_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage3-Impulse_84)+(ref_AppliedPTransform_start_stage3-FlatMap-lambda-at-core-py-3229-_85))+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-AddRandomKeys_88))+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_90))+(start_stage3/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage3/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_92))+(ref_AppliedPTransform_start_stage3-MaybeReshuffle-Reshuffle-RemoveRandomKeys_93))+(ref_AppliedPTransform_start_stage3-Map-decode-_94))+(gbk_start_stage3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage3/Read)+(ref_AppliedPTransform_stage3_map0_96))+(stage3_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk0/Read)+(ref_AppliedPTransform_stage3_map1_98))+(stage3_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk1/Read)+(ref_AppliedPTransform_stage3_map2_100))+(stage3_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk2/Read)+(ref_AppliedPTransform_stage3_map3_102))+(stage3_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk3/Read)+(ref_AppliedPTransform_stage3_map4_104))+(stage3_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk4/Read)+(ref_AppliedPTransform_stage3_map5_106))+(stage3_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage3_gbk5/Read)+(ref_AppliedPTransform_stage3_map6_108))+(stage3_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage3_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage0-Impulse_3)+(ref_AppliedPTransform_start_stage0-FlatMap-lambda-at-core-py-3229-_4))+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-AddRandomKeys_7))+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_9))+(start_stage0/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage0/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_11))+(ref_AppliedPTransform_start_stage0-MaybeReshuffle-Reshuffle-RemoveRandomKeys_12))+(ref_AppliedPTransform_start_stage0-Map-decode-_13))+(gbk_start_stage0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage0/Read)+(ref_AppliedPTransform_stage0_map0_15))+(stage0_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk0/Read)+(ref_AppliedPTransform_stage0_map1_17))+(stage0_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk1/Read)+(ref_AppliedPTransform_stage0_map2_19))+(stage0_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage6-Impulse_165)+(ref_AppliedPTransform_start_stage6-FlatMap-lambda-at-core-py-3229-_166))+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-AddRandomKeys_169))+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_171))+(start_stage6/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage6/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_173))+(ref_AppliedPTransform_start_stage6-MaybeReshuffle-Reshuffle-RemoveRandomKeys_174))+(ref_AppliedPTransform_start_stage6-Map-decode-_175))+(gbk_start_stage6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage6/Read)+(ref_AppliedPTransform_stage6_map0_177))+(stage6_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk0/Read)+(ref_AppliedPTransform_stage6_map1_179))+(stage6_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk1/Read)+(ref_AppliedPTransform_stage6_map2_181))+(stage6_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk2/Read)+(ref_AppliedPTransform_stage6_map3_183))+(stage6_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk3/Read)+(ref_AppliedPTransform_stage6_map4_185))+(stage6_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk4/Read)+(ref_AppliedPTransform_stage6_map5_187))+(stage6_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage6_gbk5/Read)+(ref_AppliedPTransform_stage6_map6_189))+(stage6_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage6_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk2/Read)+(ref_AppliedPTransform_stage0_map3_21))+(stage0_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage5-Impulse_138)+(ref_AppliedPTransform_start_stage5-FlatMap-lambda-at-core-py-3229-_139))+(ref_AppliedPTransform_start_stage5-MaybeReshuffle-Reshuffle-AddRandomKeys_142))+(ref_AppliedPTransform_start_stage5-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_144))+(start_stage5/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage5/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage5-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_146))+(ref_AppliedPTransform_start_stage5-MaybeReshuffle-Reshuffle-RemoveRandomKeys_147))+(ref_AppliedPTransform_start_stage5-Map-decode-_148))+(gbk_start_stage5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage5/Read)+(ref_AppliedPTransform_stage5_map0_150))+(stage5_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk0/Read)+(ref_AppliedPTransform_stage5_map1_152))+(stage5_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk1/Read)+(ref_AppliedPTransform_stage5_map2_154))+(stage5_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk2/Read)+(ref_AppliedPTransform_stage5_map3_156))+(stage5_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk3/Read)+(ref_AppliedPTransform_stage5_map4_158))+(stage5_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk4/Read)+(ref_AppliedPTransform_stage5_map5_160))+(stage5_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage5_gbk5/Read)+(ref_AppliedPTransform_stage5_map6_162))+(stage5_gbk6/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage5_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk3/Read)+(ref_AppliedPTransform_stage0_map4_23))+(stage0_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage0_gbk4/Read)+(ref_AppliedPTransform_stage0_map5_25))+(stage0_gbk5/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage2-Impulse_57)+(ref_AppliedPTransform_start_stage2-FlatMap-lambda-at-core-py-3229-_58))+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-AddRandomKeys_61))+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_63))+(start_stage2/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage2/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_65))+(ref_AppliedPTransform_start_stage2-MaybeReshuffle-Reshuffle-RemoveRandomKeys_66))+(ref_AppliedPTransform_start_stage2-Map-decode-_67))+(gbk_start_stage2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage2/Read)+(ref_AppliedPTransform_stage2_map0_69))+(stage2_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk0/Read)+(ref_AppliedPTransform_stage2_map1_71))+(stage2_gbk1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk1/Read)+(ref_AppliedPTransform_stage2_map2_73))+(stage2_gbk2/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk2/Read)+(ref_AppliedPTransform_stage2_map3_75))+(stage2_gbk3/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage2_gbk3/Read)+(ref_AppliedPTransform_stage2_map4_77))+(stage2_gbk4/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((ref_AppliedPTransform_start_stage1-Impulse_30)+(ref_AppliedPTransform_start_stage1-FlatMap-lambda-at-core-py-3229-_31))+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-AddRandomKeys_34))+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-ReshufflePerKey-Map-reify_timestamps-_36))+(start_stage1/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((((start_stage1/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-ReshufflePerKey-FlatMap-restore_timestam_38))+(ref_AppliedPTransform_start_stage1-MaybeReshuffle-Reshuffle-RemoveRandomKeys_39))+(ref_AppliedPTransform_start_stage1-Map-decode-_40))+(gbk_start_stage1/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((gbk_start_stage1/Read)+(ref_AppliedPTransform_stage1_map0_42))+(stage1_gbk0/Write)
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
((stage1_gbk0/Read)+(ref_AppliedPTransform_stage1_map1_44))+(stage1_gbk1/Write)
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-15' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:216)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:286)
at com.sun.proxy.$Proxy120.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1213)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1205)
at hudson.Launcher$ProcStarter.join(Launcher.java:522)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:806)
at hudson.model.Build$BuildExecution.build(Build.java:198)
at hudson.model.Build$BuildExecution.doRun(Build.java:163)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:514)
at hudson.model.Run.execute(Run.java:1888)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
at hudson.model.ResourceController.execute(ResourceController.java:99)
at hudson.model.Executor.run(Executor.java:432)
Caused by: hudson.remoting.Channel$OrderlyShutdown: Command Close created at
at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1320)
at hudson.remoting.Channel$1.handle(Channel.java:607)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:81)
Caused by: Command Close created at
at hudson.remoting.Command.<init>(Command.java:70)
at hudson.remoting.Channel$CloseCommand.<init>(Channel.java:1313)
at hudson.remoting.Channel$CloseCommand.<init>(Channel.java:1311)
at hudson.remoting.Channel.close(Channel.java:1487)
at hudson.remoting.Channel.close(Channel.java:1454)
at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1319)
... 2 more
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-15 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
