See
<https://ci-beam.apache.org/job/beam_Python_LoadTests_FnApiRunner_Microbenchmark/1455/display/redirect?page=changes>
Changes:
[Pablo Estrada] Simplify README for new users
[mmack] [BEAM-13563] Introducing common AWS ClientBuilderFactory to unify
[laraschmidt] Fix final allowskew error to properly handle a large allowedSkew
[noreply] [BEAM-13946] Add get_dummies(), a non-deferred column operation on
------------------------------------------
[...truncated 155.40 KB...]
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
((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
((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
((((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
stage0_gbk6/Read
INFO:apache_beam.runners.portability.fn_api_runner.fn_runner:Running
stage1_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 0x7f08c3bf9830>
====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function fix_side_input_pcoll_coders at 0x7f08c3bf9950> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function pack_combiners at 0x7f08c3bf9e60> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f08c3bf9ef0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_sdf at 0x7f08c3bf60e0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_gbk at 0x7f08c3bf6170> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sink_flattens at 0x7f08c3bf6290> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function greedily_fuse at 0x7f08c3bf6320> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function read_to_impulse at 0x7f08c3bf63b0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function impulse_to_input at 0x7f08c3bf6440> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sort_stages at 0x7f08c3bf6680> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function setup_timer_mapping at 0x7f08c3bf65f0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function populate_data_channel_coders at 0x7f08c3bf6710> ====================
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 0x7f08c3b7e590> 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_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
((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
((((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_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
((stage2_gbk4/Read)+(ref_AppliedPTransform_stage2_map5_79))+(stage2_gbk5/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
((((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
((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
((((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
((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
((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
stage4_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
((((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
((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
((((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
stage1_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
stage3_gbk6/Read
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
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 0x7f08c3bf9830>
====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function fix_side_input_pcoll_coders at 0x7f08c3bf9950> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function pack_combiners at 0x7f08c3bf9e60> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function lift_combiners at 0x7f08c3bf9ef0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_sdf at 0x7f08c3bf60e0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function expand_gbk at 0x7f08c3bf6170> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sink_flattens at 0x7f08c3bf6290> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function greedily_fuse at 0x7f08c3bf6320> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function read_to_impulse at 0x7f08c3bf63b0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function impulse_to_input at 0x7f08c3bf6440> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function sort_stages at 0x7f08c3bf6680> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function setup_timer_mapping at 0x7f08c3bf65f0> ====================
INFO:apache_beam.runners.portability.fn_api_runner.translations:====================
<function populate_data_channel_coders at 0x7f08c3bf6710> ====================
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 0x7f08c29bbed0> 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_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
((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
((((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
((((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
((stage2_gbk0/Read)+(ref_AppliedPTransform_stage2_map1_71))+(stage2_gbk1/Write)
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
((stage4_gbk1/Read)+(ref_AppliedPTransform_stage4_map2_127))+(stage4_gbk2/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
stage4_gbk6/Read
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
((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
((((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
((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
((((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
stage1_gbk6/Read
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
((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.direct.direct_runner:Running pipeline with
DirectRunner.
INFO:apache_beam.runners.direct.direct_runner:Running pipeline with
DirectRunner.
INFO:apache_beam.runners.direct.direct_runner:Running pipeline with
DirectRunner.
INFO:apache_beam.runners.direct.direct_runner:Running pipeline with
DirectRunner.
INFO:apache_beam.runners.direct.direct_runner:Running pipeline with
DirectRunner.
INFO:apache_beam.runners.direct.direct_runner:Running pipeline with
DirectRunner.
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-4' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:216)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:286)
at com.sun.proxy.$Proxy126.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: java.io.IOException: Pipe closed after 0 cycles
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:126)
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:105)
at
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:93)
at
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:74)
at
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:104)
at
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
FATAL: Channel "hudson.remoting.Channel@2564655:apache-beam-jenkins-4": Remote
call on apache-beam-jenkins-4 failed. The channel is closing down or has closed
down
java.io.IOException: Pipe closed after 0 cycles
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:126)
at
org.apache.sshd.common.channel.ChannelPipedInputStream.read(ChannelPipedInputStream.java:105)
at
hudson.remoting.FlightRecorderInputStream.read(FlightRecorderInputStream.java:93)
at
hudson.remoting.ChunkedInputStream.readHeader(ChunkedInputStream.java:74)
at
hudson.remoting.ChunkedInputStream.readUntilBreak(ChunkedInputStream.java:104)
at
hudson.remoting.ChunkedCommandTransport.readBlock(ChunkedCommandTransport.java:39)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:34)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Caused: hudson.remoting.ChannelClosedException: Channel
"hudson.remoting.Channel@2564655:apache-beam-jenkins-4": Remote call on
apache-beam-jenkins-4 failed. The channel is closing down or has closed down
at hudson.remoting.Channel.call(Channel.java:994)
at hudson.Launcher$RemoteLauncher.kill(Launcher.java:1148)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:526)
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)
ERROR: apache-beam-jenkins-4 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
