See <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Dataflow/691/display/redirect?page=changes>
Changes: [aromanenko.dev] [BEAM-12271] Make max width for code snippets adaptive with text blocks [samuelw] [BEAM-12253] Change Read.UnboundedSourceAsSDFRestrictionTracker to use ------------------------------------------ [...truncated 1.42 MB...] INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:38.167Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:gbk)/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:38.207Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:gbk)/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:38.251Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:gbk)/Read+Map(<lambda at validate_runner_xlang_test.py:140>)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:41.046Z: JOB_MESSAGE_BASIC: Finished operation create_col2/Impulse+create_col2/FlatMap(<lambda at core.py:2930>)+create_col2/Map(decode)+ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/MakeUnionTable0/ParMultiDo(ConstructUnionTable)+ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GBK/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:44.168Z: JOB_MESSAGE_BASIC: Finished operation create_col1/Impulse+create_col1/FlatMap(<lambda at core.py:2930>)+create_col1/Map(decode)+ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/MakeUnionTable1/ParMultiDo(ConstructUnionTable)+ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GBK/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:44.230Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GBK/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:44.271Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GBK/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:44.318Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GBK/Read+ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult)+ExternalTransform(beam:transforms:xlang:test:cgbk)/ParDo(Anonymous)/ParMultiDo(Anonymous)+Map(<lambda at validate_runner_xlang_test.py:163>)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:47.522Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2930>)+assert_that/Create/Map(decode)+assert_that/Group/pair_with_0+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:49.809Z: JOB_MESSAGE_BASIC: Finished operation Create/Impulse+Create/FlatMap(<lambda at core.py:2930>)+Create/MaybeReshuffle/Reshuffle/AddRandomKeys+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:49.885Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:49.923Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:49.972Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)+Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys+Create/Map(decode)+ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey+ExternalTransform(beam:transforms:xlang:test:compk)/Combine.GroupedValues/Partial+ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:49.377Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2930>)+assert_that/Create/Map(decode)+assert_that/Group/pair_with_0+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:52.484Z: JOB_MESSAGE_BASIC: Finished operation Create/Impulse+Create/FlatMap(<lambda at core.py:2930>)+Create/MaybeReshuffle/Reshuffle/AddRandomKeys+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:52.549Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:52.603Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:52.701Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)+Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys+Create/Map(decode)+ExternalTransform(beam:transforms:xlang:test:prefix)/Map/ParMultiDo(Anonymous)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:50.631Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:gbk)/Read+Map(<lambda at validate_runner_xlang_test.py:140>)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:50.682Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:50.719Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:50.754Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:53.828Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2930>)+assert_that/Create/Map(decode)+assert_that/Group/pair_with_0+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:56.992Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GBK/Read+ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/ConstructCoGbkResultFn/ParMultiDo(ConstructCoGbkResult)+ExternalTransform(beam:transforms:xlang:test:cgbk)/ParDo(Anonymous)/ParMultiDo(Anonymous)+Map(<lambda at validate_runner_xlang_test.py:163>)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:57.045Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:57.089Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:57.145Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:59.858Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2930>)+assert_that/Create/Map(decode)+assert_that/Group/pair_with_0+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:01.091Z: JOB_MESSAGE_BASIC: Finished operation check_even/Create/Impulse+check_even/Create/FlatMap(<lambda at core.py:2930>)+check_even/Create/Map(decode)+check_even/Group/pair_with_0+check_even/Group/Flatten/OutputIdentity+check_even/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:59.835Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:59.873Z: JOB_MESSAGE_DEBUG: Executing success step success23 INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:59.912Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:59.941Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:23:59.965Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:05.259Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:05.326Z: JOB_MESSAGE_DEBUG: Executing success step success26 INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:05.396Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:05.436Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:05.466Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:02.979Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)+Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys+Create/Map(decode)+ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey+ExternalTransform(beam:transforms:xlang:test:compk)/Combine.GroupedValues/Partial+ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:03.035Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:03.074Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:03.122Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey/Read+ExternalTransform(beam:transforms:xlang:test:compk)/Combine.GroupedValues+ExternalTransform(beam:transforms:xlang:test:compk)/Combine.GroupedValues/Extract+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:02.961Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2930>)+assert_that/Create/Map(decode)+assert_that/Group/pair_with_0+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:04.375Z: JOB_MESSAGE_BASIC: Finished operation check_odd/Create/Impulse+check_odd/Create/FlatMap(<lambda at core.py:2930>)+check_odd/Create/Map(decode)+check_odd/Group/pair_with_0+check_odd/Group/Flatten/OutputIdentity+check_odd/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:07.465Z: JOB_MESSAGE_BASIC: Finished operation Create/Impulse+Create/FlatMap(<lambda at core.py:2930>)+Create/MaybeReshuffle/Reshuffle/AddRandomKeys+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:07.526Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:07.570Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:07.662Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)+Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys+Create/Map(decode)+ExternalTransform(beam:transforms:xlang:test:partition)/ParMultiDo(Partition)+check_even/WindowInto(WindowIntoFn)+check_odd/WindowInto(WindowIntoFn)+check_even/ToVoidKey+check_even/Group/pair_with_1+check_even/Group/Flatten/OutputIdentity+check_even/Group/GroupByKey/Write+check_odd/ToVoidKey+check_odd/Group/pair_with_1+check_odd/Group/Flatten/OutputIdentity+check_odd/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:03.712Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)+Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys+Create/Map(decode)+ExternalTransform(beam:transforms:xlang:test:prefix)/Map/ParMultiDo(Anonymous)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:03.820Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:03.875Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:03.966Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:08.759Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/CreateVoid/Read(CreateSource)/Impulse+ExternalTransform(beam:transforms:xlang:test:comgl)/CreateVoid/Read(CreateSource)/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+external_1ExternalTransform-beam-transforms-xlang-test-comgl--CreateVoid-Read-CreateSource--ParDo-BoundedSourc/PairWithRestriction+external_1ExternalTransform-beam-transforms-xlang-test-comgl--CreateVoid-Read-CreateSource--ParDo-BoundedSourc/SplitWithSizing INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:09.038Z: JOB_MESSAGE_DEBUG: Value "external_1ExternalTransform-beam-transforms-xlang-test-comgl--CreateVoid-Read-CreateSource--ParDo-BoundedSourc-split-with-sizing-out3" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:08.985Z: JOB_MESSAGE_BASIC: Finished operation GenerateSequence(beam:external:java:generate_sequence:v1)/Read(BoundedCountingSource)/Impulse+GenerateSequence(beam:external:java:generate_sequence:v1)/Read(BoundedCountingSource)/ParDo(OutputSingleSource)/ParMultiDo(OutputSingleSource)+external_1GenerateSequence-beam-external-java-generate_sequence-v1--Read-BoundedCountingSource--ParDo-BoundedS/PairWithRestriction+external_1GenerateSequence-beam-external-java-generate_sequence-v1--Read-BoundedCountingSource--ParDo-BoundedS/SplitWithSizing INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:09.070Z: JOB_MESSAGE_DEBUG: Value "external_1GenerateSequence-beam-external-java-generate_sequence-v1--Read-BoundedCountingSource--ParDo-BoundedS-split-with-sizing-out3" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:09.130Z: JOB_MESSAGE_BASIC: Executing operation external_1GenerateSequence-beam-external-java-generate_sequence-v1--Read-BoundedCountingSource--ParDo-BoundedS/ProcessElementAndRestrictionWithSizing+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:12.918Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:12.980Z: JOB_MESSAGE_DEBUG: Executing success step success27 INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:13.057Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:13.105Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:13.129Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:15.486Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey/Read+ExternalTransform(beam:transforms:xlang:test:compk)/Combine.GroupedValues+ExternalTransform(beam:transforms:xlang:test:compk)/Combine.GroupedValues/Extract+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:12.446Z: JOB_MESSAGE_BASIC: Finished operation CheckSide/Create/Impulse+CheckSide/Create/FlatMap(<lambda at core.py:2930>)+CheckSide/Create/Map(decode)+CheckSide/Group/pair_with_0+CheckSide/Group/Flatten/OutputIdentity+CheckSide/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:15.541Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:15.578Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:15.630Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:11.752Z: JOB_MESSAGE_BASIC: Finished operation Create/Impulse+Create/FlatMap(<lambda at core.py:2930>)+Create/MaybeReshuffle/Reshuffle/AddRandomKeys+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/Map(reify_timestamps)+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Reify+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:11.815Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:11.857Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:11.930Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)+Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys+Create/Map(decode)+ExternalTransform(beam:transforms:xlang:test:comgl)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/Combine.GroupedValues/Partial+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:17.567Z: JOB_MESSAGE_BASIC: Finished operation Side/Impulse+Side/FlatMap(<lambda at core.py:2930>)+Side/Map(decode)+ExternalTransform(beam:transforms:xlang:test:multi)/MapElements/Map/ParMultiDo(Anonymous)+ExternalTransform(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)/GroupByKey+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Partial+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Write+CheckSide/WindowInto(WindowIntoFn)+CheckSide/ToVoidKey+CheckSide/Group/pair_with_1+CheckSide/Group/Flatten/OutputIdentity+CheckSide/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:17.648Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:17.683Z: JOB_MESSAGE_BASIC: Executing operation CheckSide/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:17.690Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:17.745Z: JOB_MESSAGE_BASIC: Finished operation CheckSide/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:17.755Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous)+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/ExtractKeyAndWindow+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:17.789Z: JOB_MESSAGE_BASIC: Executing operation CheckSide/Group/GroupByKey/Read+CheckSide/Group/Map(_merge_tagged_vals_under_key)+CheckSide/Unkey+CheckSide/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:21.356Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2930>)+assert_that/Create/Map(decode)+assert_that/Group/pair_with_0+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:19.200Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)+Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys+Create/Map(decode)+ExternalTransform(beam:transforms:xlang:test:partition)/ParMultiDo(Partition)+check_even/WindowInto(WindowIntoFn)+check_odd/WindowInto(WindowIntoFn)+check_even/ToVoidKey+check_even/Group/pair_with_1+check_even/Group/Flatten/OutputIdentity+check_even/Group/GroupByKey/Write+check_odd/ToVoidKey+check_odd/Group/pair_with_1+check_odd/Group/Flatten/OutputIdentity+check_odd/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:19.268Z: JOB_MESSAGE_BASIC: Executing operation check_odd/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:19.290Z: JOB_MESSAGE_BASIC: Executing operation check_even/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:19.308Z: JOB_MESSAGE_BASIC: Finished operation check_odd/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:19.343Z: JOB_MESSAGE_BASIC: Finished operation check_even/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:19.367Z: JOB_MESSAGE_BASIC: Executing operation check_odd/Group/GroupByKey/Read+check_odd/Group/Map(_merge_tagged_vals_under_key)+check_odd/Unkey+check_odd/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:19.414Z: JOB_MESSAGE_BASIC: Executing operation check_even/Group/GroupByKey/Read+check_even/Group/Map(_merge_tagged_vals_under_key)+check_even/Unkey+check_even/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:24.657Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Read+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/GroupByWindow+Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/FlatMap(restore_timestamps)+Create/MaybeReshuffle/Reshuffle/RemoveRandomKeys+Create/Map(decode)+ExternalTransform(beam:transforms:xlang:test:comgl)/WithKeys/AddKeys/Map/ParMultiDo(Anonymous)+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/Combine.GroupedValues/Partial+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:24.730Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:24.781Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:24.845Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey/Read+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/Combine.GroupedValues+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/Combine.GroupedValues/Extract+ExternalTransform(beam:transforms:xlang:test:comgl)/Values/Values/Map/ParMultiDo(Anonymous)+ExternalTransform(beam:transforms:xlang:test:comgl)/View.AsIterable/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write+ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/ExtractKeyAndWindow+ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/ExtractKeyAndWindow.out0/Reshard/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:23.912Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/GroupByKey/Read+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Combine.perKey(Singleton)/Combine.GroupedValues/Extract+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/Combine.globally(Singleton)/Values/Values/Map/ParMultiDo(Anonymous)+ExternalTransform(beam:transforms:xlang:test:multi)/View.AsSingleton/Combine.GloballyAsSingletonView/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/ExtractKeyAndWindow+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:23.971Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:24.016Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:24.077Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Read INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:23.741Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:23.789Z: JOB_MESSAGE_DEBUG: Executing success step success42 INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:23.838Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:23.878Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:23.905Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:27.974Z: JOB_MESSAGE_BASIC: Finished operation external_1GenerateSequence-beam-external-java-generate_sequence-v1--Read-BoundedCountingSource--ParDo-BoundedS/ProcessElementAndRestrictionWithSizing+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:28.039Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:28.093Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:28.155Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:34.457Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey/Read+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/Combine.GroupedValues+ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/Combine.GroupedValues/Extract+ExternalTransform(beam:transforms:xlang:test:comgl)/Values/Values/Map/ParMultiDo(Anonymous)+ExternalTransform(beam:transforms:xlang:test:comgl)/View.AsIterable/View.VoidKeyToMultimapMaterialization/ParDo(VoidKeyToMultimapMaterialization)/ParMultiDo(VoidKeyToMultimapMaterialization)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write+ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/ExtractKeyAndWindow+ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/ExtractKeyAndWindow.out0/Reshard/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:34.533Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/ExtractKeyAndWindow.out0/Reshard/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:34.579Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/ExtractKeyAndWindow.out0/Reshard/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:34.638Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/ExtractKeyAndWindow.out0/Reshard/Read INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.241Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.300Z: JOB_MESSAGE_DEBUG: Executing success step success24 INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.374Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.425Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.451Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:34.643Z: JOB_MESSAGE_BASIC: Finished operation check_even/Group/GroupByKey/Read+check_even/Group/Map(_merge_tagged_vals_under_key)+check_even/Unkey+check_even/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.717Z: JOB_MESSAGE_BASIC: Finished operation check_odd/Group/GroupByKey/Read+check_odd/Group/Map(_merge_tagged_vals_under_key)+check_odd/Unkey+check_odd/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.769Z: JOB_MESSAGE_DEBUG: Executing success step success43 INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.858Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.909Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:37.937Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:40.975Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2930>)+assert_that/Create/Map(decode)+assert_that/Group/pair_with_0+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:44.996Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:45.032Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:45.064Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2021-05-04_05_17_16-13471427882274738702 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:56.924Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:56.956Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:56.992Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:59.159Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:59.200Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:24:59.246Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2021-05-04_05_17_14-9550531686109168365 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2021-05-04_05_17_16-13404058392582962814 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:18.394Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:18.427Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:18.452Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:25.938Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/ExtractKeyAndWindow.out0/Reshard/Read INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:25.990Z: JOB_MESSAGE_DEBUG: Value "ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/ExtractKeyAndWindow.out0" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:26.060Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/View INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:26.112Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/View INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:26.172Z: JOB_MESSAGE_DEBUG: Value "ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#125f7c3aab6a391/View.out0" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:26.240Z: JOB_MESSAGE_BASIC: Executing operation external_1ExternalTransform-beam-transforms-xlang-test-comgl--CreateVoid-Read-CreateSource--ParDo-BoundedSourc/ProcessElementAndRestrictionWithSizing+ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2021-05-04_05_17_16-15750295947011012175 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:27.040Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:27.094Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:27.128Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:32.393Z: JOB_MESSAGE_BASIC: Finished operation external_1ExternalTransform-beam-transforms-xlang-test-comgl--CreateVoid-Read-CreateSource--ParDo-BoundedSourc/ProcessElementAndRestrictionWithSizing+ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:32.501Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:32.541Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:32.594Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2021-05-04_05_17_15-5773357295675658011 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:35.869Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:35.939Z: JOB_MESSAGE_DEBUG: Executing success step success74 INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:36.020Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:36.060Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:36.084Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:36.033Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:36.067Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:36.090Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2021-05-04_05_17_15-11240458445589886532 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:45.039Z: JOB_MESSAGE_BASIC: Finished operation CheckSide/Group/GroupByKey/Read+CheckSide/Group/Map(_merge_tagged_vals_under_key)+CheckSide/Unkey+CheckSide/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:45.259Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Read INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:45.322Z: JOB_MESSAGE_DEBUG: Value "ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/ExtractKeyAndWindow.out0" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:45.381Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/View INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:45.429Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/View INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:45.490Z: JOB_MESSAGE_DEBUG: Value "ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1221#124db6a1b083556e/View.out0" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:45.562Z: JOB_MESSAGE_BASIC: Executing operation Main2/Impulse+Main2/FlatMap(<lambda at core.py:2930>)+Main2/Map(decode)+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:45.592Z: JOB_MESSAGE_BASIC: Executing operation Main1/Impulse+Main1/FlatMap(<lambda at core.py:2930>)+Main1/Map(decode)+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:46.796Z: JOB_MESSAGE_BASIC: Finished operation Main2/Impulse+Main2/FlatMap(<lambda at core.py:2930>)+Main2/Map(decode)+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:49.387Z: JOB_MESSAGE_BASIC: Finished operation Main1/Impulse+Main1/FlatMap(<lambda at core.py:2930>)+Main1/Map(decode)+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)+assert_that/WindowInto(WindowIntoFn)+assert_that/ToVoidKey+assert_that/Group/pair_with_1+assert_that/Group/Flatten/OutputIdentity+assert_that/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:49.450Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:49.504Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:49.563Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:50.576Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Read+assert_that/Group/Map(_merge_tagged_vals_under_key)+assert_that/Unkey+assert_that/Match INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:50.634Z: JOB_MESSAGE_DEBUG: Executing success step success76 INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:50.722Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:50.797Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:25:50.824Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:26:24.775Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:26:24.801Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:26:24.833Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2021-05-04_05_17_18-17385260854180538665 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:26:40.089Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:26:40.132Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2021-05-04T12:26:40.157Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2021-05-04_05_17_17-12774475763709499285 is in state JOB_STATE_DONE Worker logs: https://console.cloud.google.com/dataflow/jobs/us-central1/2021-05-04_05_17_15-5773357295675658011?project=apache-beam-testing Worker logs: https://console.cloud.google.com/dataflow/jobs/us-central1/2021-05-04_05_17_14-9550531686109168365?project=apache-beam-testing Worker logs: https://console.cloud.google.com/dataflow/jobs/us-central1/2021-05-04_05_17_18-17385260854180538665?project=apache-beam-testing Worker logs: https://console.cloud.google.com/dataflow/jobs/us-central1/2021-05-04_05_17_16-15750295947011012175?project=apache-beam-testing Worker logs: https://console.cloud.google.com/dataflow/jobs/us-central1/2021-05-04_05_17_16-13471427882274738702?project=apache-beam-testing Worker logs: https://console.cloud.google.com/dataflow/jobs/us-central1/2021-05-04_05_17_17-12774475763709499285?project=apache-beam-testing Worker logs: https://console.cloud.google.com/dataflow/jobs/us-central1/2021-05-04_05_17_15-11240458445589886532?project=apache-beam-testing Worker logs: https://console.cloud.google.com/dataflow/jobs/us-central1/2021-05-04_05_17_16-13404058392582962814?project=apache-beam-testing test_group_by_key (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_cogroup_by_key (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_prefix (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_combine_per_key (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_generate_sequence (apache_beam.io.external.generate_sequence_test.XlangGenerateSequenceTest) ... ok test_partition (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_combine_globally (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_multi_input_output_with_sideinput (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok ---------------------------------------------------------------------- XML: nosetests-xlangValidateRunner.xml ---------------------------------------------------------------------- XML: <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Dataflow/ws/src/sdks/python/nosetests.xml> ---------------------------------------------------------------------- Ran 8 tests in 596.706s OK > Task :runners:google-cloud-dataflow-java:validatesCrossLanguageRunnerCleanup Stopping expansion service pid: 24071. Stopping expansion service pid: 24074. > Task :runners:google-cloud-dataflow-java:cleanUpDockerImages Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java:20210504120112 Untagged: us.gcr.io/apache-beam-testing/java-postcommit-it/java@sha256:df6fc4918c70c25757cb463ce81977e24e3b5f516292c801d70f27a1d8525ffa ERROR: (gcloud.container.images.delete) [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20210504120112] is not a valid name. Expected tag in the form "base:tag" or "tag" or digest in the form "sha256:<digest>" > Task :runners:google-cloud-dataflow-java:cleanUpDockerImages FAILED FAILURE: Build failed with an exception. * Where: Build file '<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Dataflow/ws/src/runners/google-cloud-dataflow-java/build.gradle'> line: 278 * What went wrong: Execution failed for task ':runners:google-cloud-dataflow-java:cleanUpDockerImages'. > Process 'command 'gcloud'' finished with non-zero exit value 1 * 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.3/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 26m 24s 113 actionable tasks: 84 executed, 25 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/4u5c3iosjcw2y 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]
