See <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark3/69/display/redirect?page=changes>
Changes: [noreply] [BEAM-9615] Misc final schema cleanups. (#14285) [noreply] [BEAM-12083] Nexmark Query 13. (#14404) ------------------------------------------ [...truncated 407.26 KB...] INFO:root:==================== <function sink_flattens at 0x7f912b256048> ==================== INFO:root:==================== <function greedily_fuse at 0x7f912b2560d0> ==================== INFO:root:==================== <function read_to_impulse at 0x7f912b256158> ==================== INFO:root:==================== <function impulse_to_input at 0x7f912b2561e0> ==================== INFO:root:==================== <function sort_stages at 0x7f912b256400> ==================== INFO:root:==================== <function setup_timer_mapping at 0x7f912b256378> ==================== INFO:root:==================== <function populate_data_channel_coders at 0x7f912b256488> ==================== INFO:root:starting control server on port 35237 INFO:root:starting data server on port 36227 INFO:root:starting state server on port 35787 INFO:root:starting logging server on port 45017 INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7f90d5c836d8> 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'ebddb1d4a55cdd9499fb33b96fd04dc34e706181153c030a41dd96bfd2f6bb51', worker_id = worker_137 INFO:root:Running (((((ref_AppliedPTransform_assert_that/Create/Impulse_11)+(ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at core.py:2963>)_12))+(ref_AppliedPTransform_assert_that/Create/Map(decode)_14))+(ref_AppliedPTransform_assert_that/Group/pair_with_0_18))+(assert_that/Group/Flatten/Transcode/0))+(assert_that/Group/Flatten/Write/0) INFO:root:Running (((ref_AppliedPTransform_Create/Impulse_3)+(ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2963>)_4))+(ref_AppliedPTransform_Create/Map(decode)_6))+(ExternalTransform(beam:transforms:xlang:test:gbk)/TestLabel/Write) INFO:root:Running ((((((ExternalTransform(beam:transforms:xlang:test:gbk)/TestLabel/Read)+(ref_AppliedPTransform_Map(<lambda at validate_runner_xlang_test.py:143>)_8))+(ref_AppliedPTransform_assert_that/WindowInto(WindowIntoFn)_15))+(ref_AppliedPTransform_assert_that/ToVoidKey_16))+(ref_AppliedPTransform_assert_that/Group/pair_with_1_19))+(assert_that/Group/Flatten/Transcode/1))+(assert_that/Group/Flatten/Write/1) 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 2.727294683456421 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 0x7f05ed282488> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:36 [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:2963>)_4\n Main1/FlatMap(<lambda at core.py:2963>):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:2963>)_9\n Main2/FlatMap(<lambda at core.py:2963>):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:2963>)_14\n Side/FlatMap(<lambda at core.py:2963>):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_8_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:multi)/Flatten_3\n ExternalTransform(beam:transforms:xlang:test:multi)/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:122>)_4\n ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:122>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:125>)_5\n ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:125>):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:2963>)_21\n assert_that/Create/FlatMap(<lambda at core.py:2963>):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:2963>)_37\n CheckSide/Create/FlatMap(<lambda at core.py:2963>):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 0x7f05ed282b70> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:36 [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:2963>)_4\n Main1/FlatMap(<lambda at core.py:2963>):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:2963>)_9\n Main2/FlatMap(<lambda at core.py:2963>):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:2963>)_14\n Side/FlatMap(<lambda at core.py:2963>):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_8_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:multi)/Flatten_3\n ExternalTransform(beam:transforms:xlang:test:multi)/Flatten:beam:transform:flatten:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:122>)_4\n ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:122>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_8_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:125>)_5\n ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:125>):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:2963>)_21\n assert_that/Create/FlatMap(<lambda at core.py:2963>):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:2963>)_37\n CheckSide/Create/FlatMap(<lambda at core.py:2963>):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 0x7f912b255620> ==================== INFO:root:==================== <function fix_side_input_pcoll_coders at 0x7f912b255730> ==================== INFO:root:==================== <function pack_combiners at 0x7f912b255b70> ==================== INFO:root:==================== <function lift_combiners at 0x7f912b255c80> ==================== INFO:root:==================== <function expand_sdf at 0x7f912b255e18> ==================== INFO:root:==================== <function expand_gbk at 0x7f912b255ea0> ==================== INFO:root:==================== <function sink_flattens at 0x7f912b256048> ==================== INFO:root:==================== <function greedily_fuse at 0x7f912b2560d0> ==================== INFO:root:==================== <function read_to_impulse at 0x7f912b256158> ==================== INFO:root:==================== <function impulse_to_input at 0x7f912b2561e0> ==================== INFO:root:==================== <function sort_stages at 0x7f912b256400> ==================== INFO:root:==================== <function setup_timer_mapping at 0x7f912b256378> ==================== INFO:root:==================== <function populate_data_channel_coders at 0x7f912b256488> ==================== INFO:root:starting control server on port 39231 INFO:root:starting data server on port 43873 INFO:root:starting state server on port 42287 INFO:root:starting logging server on port 44867 INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7f90d5c85198> 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'4ae4f2cb1878eee1813183e522018ada29a8599237dab42ba636cd4ecf2c4ba3', worker_id = worker_138 INFO:root:Running (((ref_AppliedPTransform_Main2/Impulse_8)+(ref_AppliedPTransform_Main2/FlatMap(<lambda at core.py:2963>)_9))+(ref_AppliedPTransform_Main2/Map(decode)_11))+(ref_PCollection_PCollection_2/Write) INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7f912aa8e4e0> for environment external_8_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'49536fb04b3054b1a24f0f392c50f77ac74de0e3dcfb2136165716565365491d', worker_id = worker_139 INFO:root:Running ((ref_PCollection_PCollection_2/Read)+(ExternalTransform(beam:transforms:xlang:test:multi)/Flatten/Transcode/1))+(ExternalTransform(beam:transforms:xlang:test:multi)/Flatten/Write/1) INFO:root:Running (((ref_AppliedPTransform_Main1/Impulse_3)+(ref_AppliedPTransform_Main1/FlatMap(<lambda at core.py:2963>)_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/Transcode/0))+(ExternalTransform(beam:transforms:xlang:test:multi)/Flatten/Write/0) INFO:root:Running (((ref_AppliedPTransform_Side/Impulse_13)+(ref_AppliedPTransform_Side/FlatMap(<lambda at core.py:2963>)_14))+(ref_AppliedPTransform_Side/Map(decode)_16))+(ref_PCollection_PCollection_3/Write) INFO:root:Running ((ExternalTransform(beam:transforms:xlang:test:multi)/Flatten/Read)+(external_8_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:122>)_4))+(ref_PCollection_PCollection_10/Write) INFO:root:Running (((((ref_PCollection_PCollection_10/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 ((ref_PCollection_PCollection_3/Read)+(external_8_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:multi)/Map(<lambda at expansion_service_test.py:125>)_5))+(ref_PCollection_PCollection_11/Write) INFO:root:Running (((((ref_PCollection_PCollection_11/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:2963>)_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 (((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 (((((ref_AppliedPTransform_assert_that/Create/Impulse_20)+(ref_AppliedPTransform_assert_that/Create/FlatMap(<lambda at core.py:2963>)_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 (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 12.090031623840332 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 0x7f05ed282488> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:35 [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_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:2963>)_4\n Create/FlatMap(<lambda at core.py:2963>):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_9_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:partition)/Partition(CallableWrapperPartitionFn)/ParDo(ApplyPartitionFnFn)/ParDo(ApplyPartitionFnFn)_5\n ExternalTransform(beam:transforms:xlang:test:partition)/Partition(CallableWrapperPartitionFn)/ParDo(ApplyPartitionFnFn)/ParDo(ApplyPartitionFnFn):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_9_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:223>)_6\n ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:223>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_9_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:224>)_7\n ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:224>):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:2963>)_18\n check_even/Create/FlatMap(<lambda at core.py:2963>):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:2963>)_34\n check_odd/Create/FlatMap(<lambda at core.py:2963>):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 0x7f05ed282b70> ==================== DEBUG:apache_beam.runners.portability.fn_api_runner.translations:35 [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_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:2963>)_4\n Create/FlatMap(<lambda at core.py:2963>):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_9_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:partition)/Partition(CallableWrapperPartitionFn)/ParDo(ApplyPartitionFnFn)/ParDo(ApplyPartitionFnFn)_5\n ExternalTransform(beam:transforms:xlang:test:partition)/Partition(CallableWrapperPartitionFn)/ParDo(ApplyPartitionFnFn)/ParDo(ApplyPartitionFnFn):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_9_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:223>)_6\n ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:223>):beam:transform:pardo:v1\n must follow: \n downstream_side_inputs: <unknown>', 'external_9_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:224>)_7\n ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:224>):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:2963>)_18\n check_even/Create/FlatMap(<lambda at core.py:2963>):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:2963>)_34\n check_odd/Create/FlatMap(<lambda at core.py:2963>):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 0x7f912b255620> ==================== INFO:root:==================== <function fix_side_input_pcoll_coders at 0x7f912b255730> ==================== INFO:root:==================== <function pack_combiners at 0x7f912b255b70> ==================== INFO:root:==================== <function lift_combiners at 0x7f912b255c80> ==================== INFO:root:==================== <function expand_sdf at 0x7f912b255e18> ==================== INFO:root:==================== <function expand_gbk at 0x7f912b255ea0> ==================== INFO:root:==================== <function sink_flattens at 0x7f912b256048> ==================== INFO:root:==================== <function greedily_fuse at 0x7f912b2560d0> ==================== INFO:root:==================== <function read_to_impulse at 0x7f912b256158> ==================== INFO:root:==================== <function impulse_to_input at 0x7f912b2561e0> ==================== INFO:root:==================== <function sort_stages at 0x7f912b256400> ==================== INFO:root:==================== <function setup_timer_mapping at 0x7f912b256378> ==================== INFO:root:==================== <function populate_data_channel_coders at 0x7f912b256488> ==================== INFO:root:starting control server on port 39637 INFO:root:starting data server on port 38489 INFO:root:starting state server on port 37245 INFO:root:starting logging server on port 38599 INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7f90d5c0b080> 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'4191e1be450b0b0c239ead3544fd0b6a160f74b12643e00ea9707d56f9a14522', worker_id = worker_140 INFO:root:Running (((((ref_AppliedPTransform_check_even/Create/Impulse_17)+(ref_AppliedPTransform_check_even/Create/FlatMap(<lambda at core.py:2963>)_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_AppliedPTransform_Create/Impulse_3)+(ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2963>)_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 0x7f912aa8eb38> for environment external_9_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'669ec610794bc47407ddeaf24f129f58d3185132fa675935a113685f9564ba45', worker_id = worker_141 INFO:root:Running (((((ref_PCollection_PCollection_1/Read)+(external_9_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:partition)/Partition(CallableWrapperPartitionFn)/ParDo(ApplyPartitionFnFn)/ParDo(ApplyPartitionFnFn)_5))+(external_9_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:223>)_6))+(external_9_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:partition)/Map(<lambda at expansion_service_test.py:224>)_7))+(ref_PCollection_PCollection_9/Write))+(ref_PCollection_PCollection_10/Write) INFO:root:Running (((((ref_PCollection_PCollection_9/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:Running (((((ref_PCollection_PCollection_10/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:2963>)_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:Successfully completed job in 17.9867000579834 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 0x7f05ed282488> ==================== 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:2963>)_4\n Create/FlatMap(<lambda at core.py:2963>):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_10_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:prefix)/TestLabel_3\n ExternalTransform(beam:transforms:xlang:test:prefix)/TestLabel: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:2963>)_18\n assert_that/Create/FlatMap(<lambda at core.py:2963>):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 0x7f05ed282b70> ==================== 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:2963>)_4\n Create/FlatMap(<lambda at core.py:2963>):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_10_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:prefix)/TestLabel_3\n ExternalTransform(beam:transforms:xlang:test:prefix)/TestLabel: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:2963>)_18\n assert_that/Create/FlatMap(<lambda at core.py:2963>):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 0x7f912b255620> ==================== INFO:root:==================== <function fix_side_input_pcoll_coders at 0x7f912b255730> ==================== INFO:root:==================== <function pack_combiners at 0x7f912b255b70> ==================== INFO:root:==================== <function lift_combiners at 0x7f912b255c80> ==================== INFO:root:==================== <function expand_sdf at 0x7f912b255e18> ==================== INFO:root:==================== <function expand_gbk at 0x7f912b255ea0> ==================== INFO:root:==================== <function sink_flattens at 0x7f912b256048> ==================== INFO:root:==================== <function greedily_fuse at 0x7f912b2560d0> ==================== INFO:root:==================== <function read_to_impulse at 0x7f912b256158> ==================== INFO:root:==================== <function impulse_to_input at 0x7f912b2561e0> ==================== INFO:root:==================== <function sort_stages at 0x7f912b256400> ==================== INFO:root:==================== <function setup_timer_mapping at 0x7f912b256378> ==================== INFO:root:==================== <function populate_data_channel_coders at 0x7f912b256488> ==================== INFO:root:starting control server on port 40155 INFO:root:starting data server on port 41961 INFO:root:starting state server on port 41159 INFO:root:starting logging server on port 38865 INFO:root:Created Worker handler <apache_beam.runners.portability.fn_api_runner.worker_handlers.DockerSdkWorkerHandler object at 0x7f90d5c851d0> 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'5c343ec4501915f14778e5fb4ef0527ca5f06538051a26dc61d22b312c3c166e', worker_id = worker_144 INFO:root:Running ((((ref_AppliedPTransform_Create/Impulse_3)+(ref_AppliedPTransform_Create/FlatMap(<lambda at core.py:2963>)_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 0x7f90d5c27e10> for environment external_10_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'2a6170437c24eadc3d9f7dcbe7a43261509127cff85bba5c2c1fb648b457ccc6', worker_id = worker_145 INFO:root:Running ((ref_PCollection_PCollection_1/Read)+(external_10_AppliedPTransform_ExternalTransform(beam:transforms:xlang:test:prefix)/TestLabel_3))+(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:2963>)_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.144365787506104 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_Spark3/ws/src/sdks/python/nosetests.xml> ---------------------------------------------------------------------- Ran 10 tests in 116.192s OK > Task :runners:spark:3:job-server:validatesCrossLanguageRunnerCleanup > Task :runners:spark:3:job-server:sparkJobServerCleanup FAILURE: Build 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. * 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 12s 172 actionable tasks: 150 executed, 18 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/356h2xdklb5a2 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]
