See <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/1084/display/redirect?page=changes>
Changes: [Kyle Weaver] [BEAM-10925] Java UDF type tests for input refs. [randomstep] [BEAM-12066] Bump classgraph to 4.8.104 [Kyle Weaver] [BEAM-12102] Catch and rethrow Calcite CannotPlanException. [noreply] [BEAM-11961] InfluxDBIOIT failing with unauthorized error (#14215) [noreply] Add DataFrame API changes to CHANGES.md (#14454) ------------------------------------------ [...truncated 1.01 MB...] INFO:root:Running (assert_that/Group/Flatten/Read)+(assert_that/Group/GroupByKey/Write) INFO:root:Running (((assert_that/Group/GroupByKey/Read)+(ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_22))+(ref_AppliedPTransform_assert_that/Unkey_23))+(ref_AppliedPTransform_assert_that/Match_24) INFO:root:Successfully completed job in 3.4063782691955566 seconds. INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE ok test_multi_input_output_with_sideinput (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. INFO:root:Default Python SDK image for environment is apache/beam_python3.6_sdk:2.30.0.dev INFO:root:No image given, using default Python SDK image WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. INFO:root:Default Python SDK image for environment is apache/beam_python3.6_sdk:2.30.0.dev INFO:root:Python SDK container image set to "apache/beam_python3.6_sdk:2.30.0.dev" for Docker environment INFO:apache_beam.runners.portability.fn_api_runner.translations:==================== <function lift_combiners at 0x7f0726147378> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:43 [1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1] DEBUG:apache_beam.runners.portability.fn_api_runner.translations:Stages: ['ref_AppliedPTransform_Main1/Impulse_3\n Main1/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main1/FlatMap(<lambda at core.py:2955>)_4\n Main1/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main1/Map(decode)_6\n Main1/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main2/Impulse_8\n Main2/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main2/FlatMap(<lambda at core.py:2955>)_9\n Main2/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main2/Map(decode)_11\n Main2/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Side/Impulse_13\n Side/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Side/FlatMap(<lambda at core.py:2955>)_14\n Side/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Side/Map(decode)_16\n Side/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Precombine\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Precombine:beam:transform:combine_per_key_precombine:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Group\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Group:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Merge\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Merge:beam:transform:combine_per_key_merge_accumulators:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/ExtractOutputs\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/ExtractOutputs:beam:transform:combine_per_key_extract_outputs:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/Flatten.PCollections\n ExternalTransform(beam:transforms:xlang:test:multi)/Flatten.PCollections:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/MapElements/Map/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:multi)/MapElements/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/Impulse_20\n assert_that/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at core.py:2955>)_21\n assert_that/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/Map(decode)_23\n assert_that/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_24\n assert_that/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/ToVoidKey_25\n assert_that/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/pair_with_0_27\n assert_that/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/pair_with_1_28\n assert_that/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/Flatten_29\n assert_that/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/GroupByKey_30\n assert_that/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_31\n assert_that/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Unkey_32\n assert_that/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Match_33\n assert_that/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Create/Impulse_36\n CheckSide/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Create/FlatMap(<lambda at core.py:2955>)_37\n CheckSide/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Create/Map(decode)_39\n CheckSide/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/WindowInto(WindowIntoFn)_40\n CheckSide/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/ToVoidKey_41\n CheckSide/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/pair_with_0_43\n CheckSide/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/pair_with_1_44\n CheckSide/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/Flatten_45\n CheckSide/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/GroupByKey_46\n CheckSide/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/Map(_merge_tagged_vals_under_key)_47\n CheckSide/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Unkey_48\n CheckSide/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Match_49\n CheckSide/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>'] INFO:apache_beam.runners.portability.fn_api_runner.translations:==================== <function sort_stages at 0x7f0726147a60> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:43 [1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1] DEBUG:apache_beam.runners.portability.fn_api_runner.translations:Stages: ['ref_AppliedPTransform_Main1/Impulse_3\n Main1/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main1/FlatMap(<lambda at core.py:2955>)_4\n Main1/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main1/Map(decode)_6\n Main1/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main2/Impulse_8\n Main2/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main2/FlatMap(<lambda at core.py:2955>)_9\n Main2/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Main2/Map(decode)_11\n Main2/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Side/Impulse_13\n Side/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Side/FlatMap(<lambda at core.py:2955>)_14\n Side/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Side/Map(decode)_16\n Side/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Precombine\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Precombine:beam:transform:combine_per_key_precombine:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Group\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Group:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Merge\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Merge:beam:transform:combine_per_key_merge_accumulators:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/ExtractOutputs\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/ExtractOutputs:beam:transform:combine_per_key_extract_outputs:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)\n ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/Flatten.PCollections\n ExternalTransform(beam:transforms:xlang:test:multi)/Flatten.PCollections:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8ExternalTransform(beam:transforms:xlang:test:multi)/MapElements/Map/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:multi)/MapElements/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/Impulse_20\n assert_that/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at core.py:2955>)_21\n assert_that/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/Map(decode)_23\n assert_that/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_24\n assert_that/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/ToVoidKey_25\n assert_that/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/pair_with_0_27\n assert_that/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/pair_with_1_28\n assert_that/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/Flatten_29\n assert_that/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/GroupByKey_30\n assert_that/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_31\n assert_that/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Unkey_32\n assert_that/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Match_33\n assert_that/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Create/Impulse_36\n CheckSide/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Create/FlatMap(<lambda at core.py:2955>)_37\n CheckSide/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Create/Map(decode)_39\n CheckSide/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/WindowInto(WindowIntoFn)_40\n CheckSide/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/ToVoidKey_41\n CheckSide/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/pair_with_0_43\n CheckSide/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/pair_with_1_44\n CheckSide/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/Flatten_45\n CheckSide/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/GroupByKey_46\n CheckSide/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Group/Map(_merge_tagged_vals_under_key)_47\n CheckSide/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Unkey_48\n CheckSide/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_CheckSide/Match_49\n CheckSide/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>'] INFO:apache_beam.runners.portability.portable_runner:Job state changed to STOPPED INFO:apache_beam.runners.portability.portable_runner:Job state changed to STARTING INFO:apache_beam.runners.portability.portable_runner:Job state changed to RUNNING INFO:root:==================== <function annotate_downstream_side_inputs at 0x7fd770797510> ==================== INFO:root:==================== <function fix_side_input_pcoll_coders at 0x7fd770797620> ==================== INFO:root:==================== <function pack_combiners at 0x7fd770797a60> ==================== INFO:root:==================== <function lift_combiners at 0x7fd770797b70> ==================== INFO:root:==================== <function expand_sdf at 0x7fd770797d08> ==================== INFO:root:==================== <function expand_gbk at 0x7fd770797d90> ==================== INFO:root:==================== <function sink_flattens at 0x7fd770797ea0> ==================== INFO:root:==================== <function greedily_fuse at 0x7fd770797f28> ==================== INFO:root:==================== <function read_to_impulse at 0x7fd770798048> ==================== INFO:root:==================== <function impulse_to_input at 0x7fd7707980d0> ==================== INFO:root:==================== <function sort_stages at 0x7fd7707982f0> ==================== INFO:root:==================== <function setup_timer_mapping at 0x7fd770798268> ==================== INFO:root:==================== <function populate_data_channel_coders at 0x7fd770798378> ==================== INFO:root:starting control server on port 34369 INFO:root:starting data server on port 35731 INFO:root:starting state server on port 41019 INFO:root:starting logging server on port 38649 INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7fd7700c3748> for environment ref_Environment_default_environment_1 (beam:env:docker:v1, b'\n$apache/beam_python3.6_sdk:2.30.0.dev') INFO:root:Attempting to pull image apache/beam_python3.6_sdk:2.30.0.dev INFO:root:Unable to pull image apache/beam_python3.6_sdk:2.30.0.dev, defaulting to local image if it exists INFO:root:Waiting for docker to start up. Current status is running INFO:root:Docker container is running. container_id = b'558e56ef13c15d6419359b99c0da3b8a42fef1dc0e6df3075695d374b299f5bb', worker_id = worker_43 INFO:root:Running (((ref_AppliedPTransform_Side/Impulse_13)+(ref_AppliedPTransform_Side/FlatMap(<lambda at core.py:2955>)_14))+(ref_AppliedPTransform_Side/Map(decode)_16))+(ref_PCollection_PCollection_3/Write) INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7fd770154358> for environment external_8beam:env:docker:v1 (beam:env:docker:v1, b'\n apache/beam_java8_sdk:2.30.0.dev') INFO:root:Attempting to pull image apache/beam_java8_sdk:2.30.0.dev INFO:root:Unable to pull image apache/beam_java8_sdk:2.30.0.dev, defaulting to local image if it exists INFO:root:Waiting for docker to start up. Current status is running INFO:root:Docker container is running. container_id = b'31b388430d9d2d672ebe91d79300de01ef426a6f09a1c54e66afc9ecc1660345', worker_id = worker_44 INFO:root:Running (((ref_PCollection_PCollection_3/Read)+(external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)))+(ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Precombine))+(ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Group/Write) INFO:root:Running (((ref_AppliedPTransform_Main2/Impulse_8)+(ref_AppliedPTransform_Main2/FlatMap(<lambda at core.py:2955>)_9))+(ref_AppliedPTransform_Main2/Map(decode)_11))+(ref_PCollection_PCollection_2/Write) INFO:root:Running (ref_PCollection_PCollection_2/Read)+(ExternalTransform(beam:transforms:xlang:test:multi)/Flatten.PCollections/Write/1) INFO:root:Running (((((ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Group/Read)+(ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Merge))+(ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/ExtractOutputs))+(external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous)))+(external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)))+(external_8ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization).output/Write) INFO:root:Running (((ref_AppliedPTransform_Main1/Impulse_3)+(ref_AppliedPTransform_Main1/FlatMap(<lambda at core.py:2955>)_4))+(ref_AppliedPTransform_Main1/Map(decode)_6))+(ref_PCollection_PCollection_1/Write) INFO:root:Running (ref_PCollection_PCollection_1/Read)+(ExternalTransform(beam:transforms:xlang:test:multi)/Flatten.PCollections/Write/0) INFO:root:Running ((ExternalTransform(beam:transforms:xlang:test:multi)/Flatten.PCollections/Read)+(external_8ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)))+(ref_PCollection_PCollection_11/Write) INFO:root:Running ((ref_PCollection_PCollection_3/Read)+(external_8ExternalTransform(beam:transforms:xlang:test:multi)/MapElements/Map/ParMultiDo(Anonymous)))+(ref_PCollection_PCollection_10/Write) INFO:root:Running (((((ref_PCollection_PCollection_10/Read)+(ref_AppliedPTransform_CheckSide/WindowInto(WindowIntoFn)_40))+(ref_AppliedPTransform_CheckSide/ToVoidKey_41))+(ref_AppliedPTransform_CheckSide/Group/pair_with_1_44))+(CheckSide/Group/Flatten/Transcode/1))+(CheckSide/Group/Flatten/Write/1) INFO:root:Running (((((ref_AppliedPTransform_CheckSide/Create/Impulse_36)+(ref_AppliedPTransform_CheckSide/Create/FlatMap(<lambda at core.py:2955>)_37))+(ref_AppliedPTransform_CheckSide/Create/Map(decode)_39))+(ref_AppliedPTransform_CheckSide/Group/pair_with_0_43))+(CheckSide/Group/Flatten/Transcode/0))+(CheckSide/Group/Flatten/Write/0) INFO:root:Running (CheckSide/Group/Flatten/Read)+(CheckSide/Group/GroupByKey/Write) INFO:root:Running (((((ref_AppliedPTransform_assert_that/Create/Impulse_20)+(ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at core.py:2955>)_21))+(ref_AppliedPTransform_assert_that/Create/Map(decode)_23))+(ref_AppliedPTransform_assert_that/Group/pair_with_0_27))+(assert_that/Group/Flatten/Transcode/0))+(assert_that/Group/Flatten/Write/0) INFO:root:Running (((((ref_PCollection_PCollection_11/Read)+(ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_24))+(ref_AppliedPTransform_assert_that/ToVoidKey_25))+(ref_AppliedPTransform_assert_that/Group/pair_with_1_28))+(assert_that/Group/Flatten/Transcode/1))+(assert_that/Group/Flatten/Write/1) INFO:root:Running (((CheckSide/Group/GroupByKey/Read)+(ref_AppliedPTransform_CheckSide/Group/Map(_merge_tagged_vals_under_key)_47))+(ref_AppliedPTransform_CheckSide/Unkey_48))+(ref_AppliedPTransform_CheckSide/Match_49) INFO:root:Running (assert_that/Group/Flatten/Read)+(assert_that/Group/GroupByKey/Write) INFO:root:Running (((assert_that/Group/GroupByKey/Read)+(ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_31))+(ref_AppliedPTransform_assert_that/Unkey_32))+(ref_AppliedPTransform_assert_that/Match_33) INFO:root:Successfully completed job in 9.794466972351074 seconds. INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE ok test_partition (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. INFO:root:Default Python SDK image for environment is apache/beam_python3.6_sdk:2.30.0.dev INFO:root:No image given, using default Python SDK image WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. INFO:root:Default Python SDK image for environment is apache/beam_python3.6_sdk:2.30.0.dev INFO:root:Python SDK container image set to "apache/beam_python3.6_sdk:2.30.0.dev" for Docker environment INFO:apache_beam.runners.portability.fn_api_runner.translations:==================== <function lift_combiners at 0x7f0726147378> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:33 [1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1] DEBUG:apache_beam.runners.portability.fn_api_runner.translations:Stages: ['ref_AppliedPTransform_Create/Impulse_3\n Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2955>)_4\n Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/AddRandomKeys_7\n Create/MaybeReshuffle/Reshuffle/AddRandomKeys:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)_9\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey_10\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)_11\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys_12\n Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/Map(decode)_13\n Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_9ExternalTransform(beam:transforms:xlang:test:partition)/ParMultiDo(Partition)\n ExternalTransform(beam:transforms:xlang:test:partition)/ParMultiDo(Partition):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Create/Impulse_17\n check_even/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Create/FlatMap(<lambda at core.py:2955>)_18\n check_even/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Create/Map(decode)_20\n check_even/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/WindowInto(WindowIntoFn)_21\n check_even/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/ToVoidKey_22\n check_even/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/pair_with_0_24\n check_even/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/pair_with_1_25\n check_even/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/Flatten_26\n check_even/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/GroupByKey_27\n check_even/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/Map(_merge_tagged_vals_under_key)_28\n check_even/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Unkey_29\n check_even/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Match_30\n check_even/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Create/Impulse_33\n check_odd/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Create/FlatMap(<lambda at core.py:2955>)_34\n check_odd/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Create/Map(decode)_36\n check_odd/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/WindowInto(WindowIntoFn)_37\n check_odd/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/ToVoidKey_38\n check_odd/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/pair_with_0_40\n check_odd/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/pair_with_1_41\n check_odd/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/Flatten_42\n check_odd/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/GroupByKey_43\n check_odd/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/Map(_merge_tagged_vals_under_key)_44\n check_odd/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Unkey_45\n check_odd/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Match_46\n check_odd/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>'] INFO:apache_beam.runners.portability.fn_api_runner.translations:==================== <function sort_stages at 0x7f0726147a60> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:33 [1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1] DEBUG:apache_beam.runners.portability.fn_api_runner.translations:Stages: ['ref_AppliedPTransform_Create/Impulse_3\n Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2955>)_4\n Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/AddRandomKeys_7\n Create/MaybeReshuffle/Reshuffle/AddRandomKeys:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)_9\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey_10\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)_11\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys_12\n Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/Map(decode)_13\n Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_9ExternalTransform(beam:transforms:xlang:test:partition)/ParMultiDo(Partition)\n ExternalTransform(beam:transforms:xlang:test:partition)/ParMultiDo(Partition):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Create/Impulse_17\n check_even/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Create/FlatMap(<lambda at core.py:2955>)_18\n check_even/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Create/Map(decode)_20\n check_even/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/WindowInto(WindowIntoFn)_21\n check_even/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/ToVoidKey_22\n check_even/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/pair_with_0_24\n check_even/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/pair_with_1_25\n check_even/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/Flatten_26\n check_even/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/GroupByKey_27\n check_even/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Group/Map(_merge_tagged_vals_under_key)_28\n check_even/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Unkey_29\n check_even/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_even/Match_30\n check_even/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Create/Impulse_33\n check_odd/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Create/FlatMap(<lambda at core.py:2955>)_34\n check_odd/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Create/Map(decode)_36\n check_odd/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/WindowInto(WindowIntoFn)_37\n check_odd/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/ToVoidKey_38\n check_odd/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/pair_with_0_40\n check_odd/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/pair_with_1_41\n check_odd/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/Flatten_42\n check_odd/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/GroupByKey_43\n check_odd/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Group/Map(_merge_tagged_vals_under_key)_44\n check_odd/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Unkey_45\n check_odd/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_check_odd/Match_46\n check_odd/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>'] INFO:apache_beam.runners.portability.portable_runner:Job state changed to STOPPED INFO:apache_beam.runners.portability.portable_runner:Job state changed to STARTING INFO:apache_beam.runners.portability.portable_runner:Job state changed to RUNNING INFO:root:==================== <function annotate_downstream_side_inputs at 0x7fd770797510> ==================== INFO:root:==================== <function fix_side_input_pcoll_coders at 0x7fd770797620> ==================== INFO:root:==================== <function pack_combiners at 0x7fd770797a60> ==================== INFO:root:==================== <function lift_combiners at 0x7fd770797b70> ==================== INFO:root:==================== <function expand_sdf at 0x7fd770797d08> ==================== INFO:root:==================== <function expand_gbk at 0x7fd770797d90> ==================== INFO:root:==================== <function sink_flattens at 0x7fd770797ea0> ==================== INFO:root:==================== <function greedily_fuse at 0x7fd770797f28> ==================== INFO:root:==================== <function read_to_impulse at 0x7fd770798048> ==================== INFO:root:==================== <function impulse_to_input at 0x7fd7707980d0> ==================== INFO:root:==================== <function sort_stages at 0x7fd7707982f0> ==================== INFO:root:==================== <function setup_timer_mapping at 0x7fd770798268> ==================== INFO:root:==================== <function populate_data_channel_coders at 0x7fd770798378> ==================== INFO:root:starting control server on port 37117 INFO:root:starting data server on port 37933 INFO:root:starting state server on port 34341 INFO:root:starting logging server on port 41275 INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7fd7700ef080> for environment ref_Environment_default_environment_1 (beam:env:docker:v1, b'\n$apache/beam_python3.6_sdk:2.30.0.dev') INFO:root:Attempting to pull image apache/beam_python3.6_sdk:2.30.0.dev INFO:root:Unable to pull image apache/beam_python3.6_sdk:2.30.0.dev, defaulting to local image if it exists INFO:root:Waiting for docker to start up. Current status is running INFO:root:Docker container is running. container_id = b'24c57be7732bdd45a60da7266ed44e794916b22e93c89977b939800ecfdf9c9d', worker_id = worker_45 INFO:root:Running ((((ref_AppliedPTransform_Create/Impulse_3)+(ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2955>)_4))+(ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/AddRandomKeys_7))+(ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)_9))+(Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write) INFO:root:Running ((((Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)_11))+(ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys_12))+(ref_AppliedPTransform_Create/Map(decode)_13))+(ref_PCollection_PCollection_1/Write) INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7fd7700de5f8> for environment external_9beam:env:docker:v1 (beam:env:docker:v1, b'\n apache/beam_java8_sdk:2.30.0.dev') INFO:root:Attempting to pull image apache/beam_java8_sdk:2.30.0.dev INFO:root:Unable to pull image apache/beam_java8_sdk:2.30.0.dev, defaulting to local image if it exists INFO:root:Waiting for docker to start up. Current status is running INFO:root:Docker container is running. container_id = b'c20a204ef1e93a79d919d17a97feeeca39212706414d6088475ade97603f12d5', worker_id = worker_46 INFO:root:Running (((ref_PCollection_PCollection_1/Read)+(external_9ExternalTransform(beam:transforms:xlang:test:partition)/ParMultiDo(Partition)))+(ref_PCollection_PCollection_10/Write))+(ref_PCollection_PCollection_9/Write) INFO:root:Running (((((ref_PCollection_PCollection_9/Read)+(ref_AppliedPTransform_check_odd/WindowInto(WindowIntoFn)_37))+(ref_AppliedPTransform_check_odd/ToVoidKey_38))+(ref_AppliedPTransform_check_odd/Group/pair_with_1_41))+(check_odd/Group/Flatten/Transcode/1))+(check_odd/Group/Flatten/Write/1) INFO:root:Running (((((ref_AppliedPTransform_check_odd/Create/Impulse_33)+(ref_AppliedPTransform_check_odd/Create/FlatMap(<lambda at core.py:2955>)_34))+(ref_AppliedPTransform_check_odd/Create/Map(decode)_36))+(ref_AppliedPTransform_check_odd/Group/pair_with_0_40))+(check_odd/Group/Flatten/Transcode/0))+(check_odd/Group/Flatten/Write/0) INFO:root:Running (check_odd/Group/Flatten/Read)+(check_odd/Group/GroupByKey/Write) INFO:root:Running (((check_odd/Group/GroupByKey/Read)+(ref_AppliedPTransform_check_odd/Group/Map(_merge_tagged_vals_under_key)_44))+(ref_AppliedPTransform_check_odd/Unkey_45))+(ref_AppliedPTransform_check_odd/Match_46) INFO:root:Running (((((ref_AppliedPTransform_check_even/Create/Impulse_17)+(ref_AppliedPTransform_check_even/Create/FlatMap(<lambda at core.py:2955>)_18))+(ref_AppliedPTransform_check_even/Create/Map(decode)_20))+(ref_AppliedPTransform_check_even/Group/pair_with_0_24))+(check_even/Group/Flatten/Transcode/0))+(check_even/Group/Flatten/Write/0) INFO:root:Running (((((ref_PCollection_PCollection_10/Read)+(ref_AppliedPTransform_check_even/WindowInto(WindowIntoFn)_21))+(ref_AppliedPTransform_check_even/ToVoidKey_22))+(ref_AppliedPTransform_check_even/Group/pair_with_1_25))+(check_even/Group/Flatten/Transcode/1))+(check_even/Group/Flatten/Write/1) INFO:root:Running (check_even/Group/Flatten/Read)+(check_even/Group/GroupByKey/Write) INFO:root:Running (((check_even/Group/GroupByKey/Read)+(ref_AppliedPTransform_check_even/Group/Map(_merge_tagged_vals_under_key)_28))+(ref_AppliedPTransform_check_even/Unkey_29))+(ref_AppliedPTransform_check_even/Match_30) INFO:root:Successfully completed job in 15.887445211410522 seconds. INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE ok test_prefix (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] DEBUG:root:Unhandled type_constraint: Union[] WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. INFO:root:Default Python SDK image for environment is apache/beam_python3.6_sdk:2.30.0.dev INFO:root:No image given, using default Python SDK image WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. INFO:root:Default Python SDK image for environment is apache/beam_python3.6_sdk:2.30.0.dev INFO:root:Python SDK container image set to "apache/beam_python3.6_sdk:2.30.0.dev" for Docker environment INFO:apache_beam.runners.portability.fn_api_runner.translations:==================== <function lift_combiners at 0x7f0726147378> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:21 [1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1] DEBUG:apache_beam.runners.portability.fn_api_runner.translations:Stages: ['ref_AppliedPTransform_Create/Impulse_3\n Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2955>)_4\n Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/AddRandomKeys_7\n Create/MaybeReshuffle/Reshuffle/AddRandomKeys:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)_9\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey_10\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)_11\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys_12\n Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/Map(decode)_13\n Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_10ExternalTransform(beam:transforms:xlang:test:prefix)/Map/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:prefix)/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/Impulse_17\n assert_that/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at core.py:2955>)_18\n assert_that/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/Map(decode)_20\n assert_that/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_21\n assert_that/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/ToVoidKey_22\n assert_that/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/pair_with_0_24\n assert_that/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/pair_with_1_25\n assert_that/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/Flatten_26\n assert_that/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/GroupByKey_27\n assert_that/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_28\n assert_that/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Unkey_29\n assert_that/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Match_30\n assert_that/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>'] INFO:apache_beam.runners.portability.fn_api_runner.translations:==================== <function sort_stages at 0x7f0726147a60> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:21 [1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1] DEBUG:apache_beam.runners.portability.fn_api_runner.translations:Stages: ['ref_AppliedPTransform_Create/Impulse_3\n Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2955>)_4\n Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/AddRandomKeys_7\n Create/MaybeReshuffle/Reshuffle/AddRandomKeys:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)_9\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey_10\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)_11\n Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys_12\n Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_Create/Map(decode)_13\n Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_10ExternalTransform(beam:transforms:xlang:test:prefix)/Map/ParMultiDo(Anonymous)\n ExternalTransform(beam:transforms:xlang:test:prefix)/Map/ParMultiDo(Anonymous):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/Impulse_17\n assert_that/Create/Impulse:beam:transform:impulse:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at core.py:2955>)_18\n assert_that/Create/FlatMap(<lambda at core.py:2955>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Create/Map(decode)_20\n assert_that/Create/Map(decode):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_21\n assert_that/WindowInto(WindowIntoFn):beam:transform:window_into:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/ToVoidKey_22\n assert_that/ToVoidKey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/pair_with_0_24\n assert_that/Group/pair_with_0:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/pair_with_1_25\n assert_that/Group/pair_with_1:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/Flatten_26\n assert_that/Group/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/GroupByKey_27\n assert_that/Group/GroupByKey:beam:transform:group_by_key:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_28\n assert_that/Group/Map(_merge_tagged_vals_under_key):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Unkey_29\n assert_that/Unkey:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'ref_AppliedPTransform_assert_that/Match_30\n assert_that/Match:beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>'] INFO:apache_beam.runners.portability.portable_runner:Job state changed to STOPPED INFO:apache_beam.runners.portability.portable_runner:Job state changed to STARTING INFO:apache_beam.runners.portability.portable_runner:Job state changed to RUNNING INFO:root:==================== <function annotate_downstream_side_inputs at 0x7fd770797510> ==================== INFO:root:==================== <function fix_side_input_pcoll_coders at 0x7fd770797620> ==================== INFO:root:==================== <function pack_combiners at 0x7fd770797a60> ==================== INFO:root:==================== <function lift_combiners at 0x7fd770797b70> ==================== INFO:root:==================== <function expand_sdf at 0x7fd770797d08> ==================== INFO:root:==================== <function expand_gbk at 0x7fd770797d90> ==================== INFO:root:==================== <function sink_flattens at 0x7fd770797ea0> ==================== INFO:root:==================== <function greedily_fuse at 0x7fd770797f28> ==================== INFO:root:==================== <function read_to_impulse at 0x7fd770798048> ==================== INFO:root:==================== <function impulse_to_input at 0x7fd7707980d0> ==================== INFO:root:==================== <function sort_stages at 0x7fd7707982f0> ==================== INFO:root:==================== <function setup_timer_mapping at 0x7fd770798268> ==================== INFO:root:==================== <function populate_data_channel_coders at 0x7fd770798378> ==================== INFO:root:starting control server on port 35841 INFO:root:starting data server on port 35543 INFO:root:starting state server on port 39247 INFO:root:starting logging server on port 46367 INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7fd770231c50> for environment ref_Environment_default_environment_1 (beam:env:docker:v1, b'\n$apache/beam_python3.6_sdk:2.30.0.dev') INFO:root:Attempting to pull image apache/beam_python3.6_sdk:2.30.0.dev INFO:root:Unable to pull image apache/beam_python3.6_sdk:2.30.0.dev, defaulting to local image if it exists INFO:root:Waiting for docker to start up. Current status is running INFO:root:Docker container is running. container_id = b'986a14c40b8c7e99cc162cb3144ac1ae487430e595bc903c31065e985b3fb657', worker_id = worker_49 INFO:root:Running ((((ref_AppliedPTransform_Create/Impulse_3)+(ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2955>)_4))+(ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/AddRandomKeys_7))+(ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)_9))+(Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write) INFO:root:Running ((((Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read)+(ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)_11))+(ref_AppliedPTransform_Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys_12))+(ref_AppliedPTransform_Create/Map(decode)_13))+(ref_PCollection_PCollection_1/Write) INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7fd7700e3828> for environment external_10beam:env:docker:v1 (beam:env:docker:v1, b'\n apache/beam_java8_sdk:2.30.0.dev') INFO:root:Attempting to pull image apache/beam_java8_sdk:2.30.0.dev INFO:root:Unable to pull image apache/beam_java8_sdk:2.30.0.dev, defaulting to local image if it exists INFO:root:Waiting for docker to start up. Current status is running INFO:root:Docker container is running. container_id = b'ea39201b4542b3b5d7fe28a8b56bb73be5ed86c722eb62f075e5dd3abe63d358', worker_id = worker_50 INFO:root:Running ((ref_PCollection_PCollection_1/Read)+(external_10ExternalTransform(beam:transforms:xlang:test:prefix)/Map/ParMultiDo(Anonymous)))+(ref_PCollection_PCollection_9/Write) INFO:root:Running (((((ref_PCollection_PCollection_9/Read)+(ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_21))+(ref_AppliedPTransform_assert_that/ToVoidKey_22))+(ref_AppliedPTransform_assert_that/Group/pair_with_1_25))+(assert_that/Group/Flatten/Transcode/1))+(assert_that/Group/Flatten/Write/1) INFO:root:Running (((((ref_AppliedPTransform_assert_that/Create/Impulse_17)+(ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at core.py:2955>)_18))+(ref_AppliedPTransform_assert_that/Create/Map(decode)_20))+(ref_AppliedPTransform_assert_that/Group/pair_with_0_24))+(assert_that/Group/Flatten/Transcode/0))+(assert_that/Group/Flatten/Write/0) INFO:root:Running (assert_that/Group/Flatten/Read)+(assert_that/Group/GroupByKey/Write) INFO:root:Running (((assert_that/Group/GroupByKey/Read)+(ref_AppliedPTransform_assert_that/Group/Map(_merge_tagged_vals_under_key)_28))+(ref_AppliedPTransform_assert_that/Unkey_29))+(ref_AppliedPTransform_assert_that/Match_30) INFO:root:Successfully completed job in 13.849671602249146 seconds. INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE ok ---------------------------------------------------------------------- XML: nosetests-xlangValidateRunner.xml ---------------------------------------------------------------------- XML: <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/nosetests.xml> ---------------------------------------------------------------------- Ran 10 tests in 156.087s OK > Task :sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerCleanup Stopping expansion service pid: 9149. Skipping invalid pid: 9152. > Task :sdks:python:test-suites:direct:xlang:fnApiJobServerCleanup Killing process at 24428 FAILURE: Build completed with 2 failures. 1: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':sdks:java:io:mongodb:compileJava'. > Compilation failed; see the compiler error output for details. * Try: Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights. ============================================================================== 2: Task failed with an exception. ----------- * What went wrong: Execution failed for task ':sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerJavaUsingPythonOnly'. > There were failing tests. See the report at: > file://<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/test-suites/direct/xlang/build/reports/tests/validatesCrossLanguageRunnerJavaUsingPythonOnly/index.html> * Try: Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output. Run with --scan to get full insights. ============================================================================== * Get more help at https://help.gradle.org Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0. Use '--warning-mode all' to show the individual deprecation warnings. See https://docs.gradle.org/6.8/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 40m 24s 159 actionable tasks: 147 executed, 8 from cache, 4 up-to-date Gradle was unable to watch the file system for changes. The inotify watches limit is too low. Publishing build scan... https://gradle.com/s/czkz34yjtrzc6 Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
