See <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Dataflow/139/display/redirect>
Changes: ------------------------------------------ [...truncated 922.84 KB...] INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:31.340Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:36.043Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:36.081Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:39.262Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:39.303Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:36.716Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:36.748Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:39.324Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:39.348Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:39.899Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:38:39.928Z: JOB_MESSAGE_DETAILED: Workers have started successfully. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:08.464Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:11.645Z: JOB_MESSAGE_BASIC: Finished operation Create/Impulse+Create/FlatMap(<lambda at core.py:2963>)+Create/Map(decode)+ExternalTransform(beam:transforms:xlang:test:gbk)/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:11.711Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:gbk)/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:11.765Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:gbk)/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:12.073Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:gbk)/Read+Map(<lambda at validate_runner_xlang_test.py:143>)+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:2020-12-17T12:43:21.334Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:gbk)/Read+Map(<lambda at validate_runner_xlang_test.py:143>)+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:2020-12-17T12:43:21.507Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:21.602Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:21.736Z: 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:2020-12-17T12:43:30.505Z: 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:2020-12-17T12:43:30.581Z: JOB_MESSAGE_DEBUG: Executing success step success23 INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:30.660Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:30.711Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:30.748Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:30.003Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:33.090Z: JOB_MESSAGE_BASIC: Finished operation Create/Impulse+Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:33.293Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:33.329Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:33.379Z: 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:2020-12-17T12:43:38.260Z: JOB_MESSAGE_BASIC: Finished operation create_col1/Impulse+create_col1/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:37.070Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:38.835Z: 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(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/PairWithRestriction+external_1GenerateSequence(beam:external:java:generate_sequence:v1)/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/SplitWithSizing INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:39.296Z: JOB_MESSAGE_DEBUG: Value "external_1GenerateSequence(beam:external:java:generate_sequence:v1)/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)-split-with-sizing-out3" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:39.442Z: JOB_MESSAGE_BASIC: Executing operation external_1GenerateSequence(beam:external:java:generate_sequence:v1)/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/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:2020-12-17T12:43:41.598Z: JOB_MESSAGE_BASIC: Finished operation create_col2/Impulse+create_col2/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:41.680Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GBK/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:41.724Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:cgbk)/CoGroupByKey/GBK/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:41.778Z: 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:166>)+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:2020-12-17T12:43:40.184Z: JOB_MESSAGE_BASIC: Finished operation Create/Impulse+Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:40.257Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:40.318Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:40.389Z: 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:2020-12-17T12:43:44.917Z: 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:2020-12-17T12:43:44.970Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:45.047Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:45.203Z: 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:2020-12-17T12:43:48.604Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:51.959Z: JOB_MESSAGE_BASIC: Finished operation Create/Impulse+Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:52.039Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:52.079Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:52.193Z: 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:2020-12-17T12:43:52.105Z: 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:166>)+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:2020-12-17T12:43:54.123Z: 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:2020-12-17T12:43:54.185Z: JOB_MESSAGE_DEBUG: Executing success step success27 INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:54.254Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:54.301Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:54.328Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:51.823Z: JOB_MESSAGE_BASIC: Finished operation CheckSide/Create/Impulse+CheckSide/Create/FlatMap(<lambda at core.py:2963>)+CheckSide/Create/Map(decode)+CheckSide/Group/pair_with_0+CheckSide/Group/Flatten/OutputIdentity+CheckSide/Group/GroupByKey/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:50.912Z: 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:2020-12-17T12:43:51.003Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:51.098Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:compk)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:51.201Z: 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:2020-12-17T12:43:54.750Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:55.187Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:55.257Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:55.300Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:55.435Z: 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:2020-12-17T12:43:58.011Z: 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(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/PairWithRestriction+external_1ExternalTransform(beam:transforms:xlang:test:comgl)/CreateVoid/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/SplitWithSizing INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:58.066Z: JOB_MESSAGE_DEBUG: Value "external_1ExternalTransform(beam:transforms:xlang:test:comgl)/CreateVoid/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)-split-with-sizing-out3" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:56.051Z: JOB_MESSAGE_BASIC: Finished operation Create/Impulse+Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:56.167Z: JOB_MESSAGE_BASIC: Executing operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:56.220Z: JOB_MESSAGE_BASIC: Finished operation Create/MaybeReshuffle/Reshuffle/ReshufflePerKey/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:56.304Z: 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:2020-12-17T12:43:59.185Z: JOB_MESSAGE_BASIC: Finished operation check_even/Create/Impulse+check_even/Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:57.478Z: JOB_MESSAGE_BASIC: Finished operation Side/Impulse+Side/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:43:57.658Z: 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:2020-12-17T12:43:57.808Z: 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:2020-12-17T12:43:57.850Z: JOB_MESSAGE_BASIC: Executing operation CheckSide/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:57.964Z: 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>:1225#124db6a1b083556e/ExtractKeyAndWindow+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:58.004Z: JOB_MESSAGE_BASIC: Finished operation CheckSide/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:43:58.127Z: 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:2020-12-17T12:44:00.897Z: 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:2020-12-17T12:44:00.978Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:01.045Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:01.103Z: 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:2020-12-17T12:44:01.607Z: JOB_MESSAGE_BASIC: Finished operation external_1GenerateSequence(beam:external:java:generate_sequence:v1)/Read(BoundedCountingSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/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:2020-12-17T12:44:01.711Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:01.766Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:01.841Z: 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:2020-12-17T12:44:07.753Z: 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:2020-12-17T12:44:07.839Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:07.877Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/Combine.perKey(SumLong)/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:07.930Z: 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>:1225#7684676c46350e7d/ExtractKeyAndWindow+ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/ExtractKeyAndWindow.out0/Reshard/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:04.455Z: 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:2020-12-17T12:44:04.508Z: JOB_MESSAGE_DEBUG: Executing success step success26 INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:04.582Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:04.619Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:04.643Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:07.827Z: JOB_MESSAGE_BASIC: Finished operation check_odd/Create/Impulse+check_odd/Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:44:10.028Z: 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:2020-12-17T12:44:10.850Z: 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:2020-12-17T12:44:10.917Z: JOB_MESSAGE_DEBUG: Executing success step success24 INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:10.977Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:11.014Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:11.041Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:13.426Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:13.466Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:13.497Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:14.713Z: 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:2020-12-17T12:44:14.803Z: JOB_MESSAGE_BASIC: Executing operation check_odd/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:14.825Z: JOB_MESSAGE_BASIC: Executing operation check_even/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:14.856Z: JOB_MESSAGE_BASIC: Finished operation check_even/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:14.856Z: JOB_MESSAGE_BASIC: Finished operation check_odd/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:14.936Z: 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:2020-12-17T12:44:14.957Z: 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:2020-12-17T12:44:13.396Z: 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>:1225#124db6a1b083556e/ExtractKeyAndWindow+ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:13.539Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:13.620Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:13.793Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Read INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:10.274Z: 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:2020-12-17T12:44:10.338Z: JOB_MESSAGE_DEBUG: Executing success step success42 INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:10.411Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:10.468Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:10.497Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:14.310Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Create/Impulse+assert_that/Create/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:44:17.672Z: 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>:1225#7684676c46350e7d/ExtractKeyAndWindow+ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/ExtractKeyAndWindow.out0/Reshard/Write INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:17.730Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/ExtractKeyAndWindow.out0/Reshard/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:17.765Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/ExtractKeyAndWindow.out0/Reshard/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:17.847Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/ExtractKeyAndWindow.out0/Reshard/Read INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2020-12-17_04_37_36-1115460016648996162 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:30.100Z: 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:2020-12-17T12:44:32.260Z: 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:2020-12-17T12:44:32.456Z: JOB_MESSAGE_DEBUG: Executing success step success43 INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:32.599Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:32.662Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:32.709Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:35.820Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:35.870Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:35.896Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2020-12-17_04_37_36-13604951552112045866 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:52.971Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:53.013Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:53.051Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:55.679Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:55.722Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:55.761Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:55.456Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:55.501Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:44:55.540Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2020-12-17_04_37_36-14408590475049202451 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2020-12-17_04_37_34-8343580850443936759 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2020-12-17_04_37_36-12727536384728126095 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:19.655Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/ExtractKeyAndWindow.out0/Reshard/Read INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:19.738Z: JOB_MESSAGE_DEBUG: Value "ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/ExtractKeyAndWindow.out0" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:19.838Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/View INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:19.931Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/View INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:20.064Z: JOB_MESSAGE_DEBUG: Value "ExternalTransform(beam:transforms:xlang:test:multi)/ParDo(Anonymous)/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#124db6a1b083556e/View.out0" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:20.137Z: JOB_MESSAGE_BASIC: Executing operation Main2/Impulse+Main2/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:45:20.173Z: JOB_MESSAGE_BASIC: Executing operation Main1/Impulse+Main1/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:45:21.313Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/ExtractKeyAndWindow.out0/Reshard/Read INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:21.355Z: JOB_MESSAGE_DEBUG: Value "ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/ExtractKeyAndWindow.out0" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:21.415Z: JOB_MESSAGE_BASIC: Executing operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/View INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:21.456Z: JOB_MESSAGE_BASIC: Finished operation ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/View INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:21.504Z: JOB_MESSAGE_DEBUG: Value "ExternalTransform(beam:transforms:xlang:test:comgl)/ProduceDefault/ParMultiDo(Anonymous)/View-org.apache.beam.sdk.values.PCollectionViews$SimplePCollectionView.<init>:1225#7684676c46350e7d/View.out0" materialized. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:21.562Z: JOB_MESSAGE_BASIC: Executing operation external_1ExternalTransform(beam:transforms:xlang:test:comgl)/CreateVoid/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/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:2020-12-17T12:45:22.618Z: JOB_MESSAGE_BASIC: Finished operation Main2/Impulse+Main2/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:45:25.409Z: JOB_MESSAGE_BASIC: Finished operation Main1/Impulse+Main1/FlatMap(<lambda at core.py:2963>)+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:2020-12-17T12:45:25.494Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:25.547Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:25.613Z: 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:2020-12-17T12:45:21.507Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:21.558Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:21.601Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2020-12-17_04_37_36-808579663021580876 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:31.500Z: JOB_MESSAGE_BASIC: Finished operation external_1ExternalTransform(beam:transforms:xlang:test:comgl)/CreateVoid/Read(CreateSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper)/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:2020-12-17T12:45:31.572Z: JOB_MESSAGE_BASIC: Executing operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:31.636Z: JOB_MESSAGE_BASIC: Finished operation assert_that/Group/GroupByKey/Close INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:31.712Z: 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:2020-12-17T12:45:31.675Z: 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:2020-12-17T12:45:31.736Z: JOB_MESSAGE_DEBUG: Executing success step success76 INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:31.833Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:31.902Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:31.931Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:37.722Z: 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:2020-12-17T12:45:37.798Z: JOB_MESSAGE_DEBUG: Executing success step success74 INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:37.902Z: JOB_MESSAGE_DETAILED: Cleaning up. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:37.953Z: JOB_MESSAGE_DEBUG: Starting worker pool teardown. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:45:37.982Z: JOB_MESSAGE_BASIC: Stopping worker pool... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:46:21.359Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:46:21.414Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:46:21.454Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:46:24.281Z: JOB_MESSAGE_DETAILED: Autoscaling: Resized worker pool from 1 to 0. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:46:24.312Z: JOB_MESSAGE_BASIC: Worker pool stopped. INFO:apache_beam.runners.dataflow.dataflow_runner:2020-12-17T12:46:24.336Z: JOB_MESSAGE_DEBUG: Tearing down pending resources... INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2020-12-17_04_37_36-2245159608998144069 is in state JOB_STATE_DONE INFO:apache_beam.runners.dataflow.dataflow_runner:Job 2020-12-17_04_37_35-4459474354890689040 is in state JOB_STATE_DONE test_group_by_key (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_prefix (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_cogroup_by_key (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_generate_sequence (apache_beam.io.external.generate_sequence_test.XlangGenerateSequenceTest) ... ok test_combine_per_key (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_partition (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_multi_input_output_with_sideinput (apache_beam.transforms.validate_runner_xlang_test.ValidateRunnerXlangTest) ... ok test_combine_globally (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 633.098s OK > Task :runners:google-cloud-dataflow-java:validatesCrossLanguageRunnerCleanup > Task :runners:google-cloud-dataflow-java:cleanUpDockerImages ERROR: (gcloud.container.images.delete) [us.gcr.io/apache-beam-testing/java-postcommit-it/java:20201217120051] 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: 274 * 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.7/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 46m 14s 116 actionable tasks: 86 executed, 26 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/rhdpx23h5dgic 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]
