See
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/4715/display/redirect>
Changes:
------------------------------------------
[...truncated 46.76 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (15/16)#0
(127ee14e1127555d0a3a888f0666dac9).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (15/16)#0
(394dd8faaa7f2d51dbbfaf369dc71a32) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-26'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-27'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-33'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-30'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (4/16)#0 (b149110eb87fe88bf21f138b5a7c37b9)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (4/16)#0
(b149110eb87fe88bf21f138b5a7c37b9).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (4/16)#0
(ed8ab6f8fb8097a7685a8dd9ff40ced5) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-32'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (8/16)#0 (20ec58de8d4cfa47382b925a7de42daf)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (8/16)#0
(20ec58de8d4cfa47382b925a7de42daf).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (8/16)#0
(7cc2249288e3346367066d41c426c725) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-29'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (11/16)#0 (b9c665b31bab7cb40a39c0f1ad306d9c)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (11/16)#0
(dd3426b98f3b0d8ffa7afa5bc08a8a6a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (11/16)#0 (dd3426b98f3b0d8ffa7afa5bc08a8a6a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-28'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-31'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-24'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-25'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-23'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (13/16)#0 (23d5db2a6f57adc10f12a7d8bc7dd3f8)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (13/16)#0
(23d5db2a6f57adc10f12a7d8bc7dd3f8).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (13/16)#0
(ade3aed3244fb5952046d81564137694) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-22'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 2-19'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for GroupReduce (GroupReduce at
assert_that/Group/CoGroupByKeyImpl/GroupByKey) (7/16)#0
(258866609a19180a8ee9cedc43ce5aa7).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for GroupReduce (GroupReduce at
assert_that/Group/CoGroupByKeyImpl/GroupByKey) (11/16)#0
(41e9579e3a2d071eff5fba0563f0a3a6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:45 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for GroupReduce (GroupReduce at
assert_that/Group/CoGroupByKeyImpl/GroupByKey) (10/16)#0
(69639efe3ef7c5e1289ee5e1d336b8d2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (13/16)#0 (ade3aed3244fb5952046d81564137694).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (11/16)#0
(b9c665b31bab7cb40a39c0f1ad306d9c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (8/16)#0 (7cc2249288e3346367066d41c426c725).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (4/16)#0 (ed8ab6f8fb8097a7685a8dd9ff40ced5).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (15/16)#0 (394dd8faaa7f2d51dbbfaf369dc71a32).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task CHAIN MapPartition (MapPartition at [3]Read with BigQuery Storage
API/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap
(FlatMap at ExtractOutput[0]) (4/16)#0 1d8dcefa86cd2221589391b48e5c907f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task FlatMap (FlatMap at ExtractOutput[1]) (14/16)#0
96f35edce87ec067bc56ba4e88e6910d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for GroupReduce (GroupReduce at
assert_that/Group/CoGroupByKeyImpl/GroupByKey) (9/16)#0
(20f46315bba6f64c271cde56dad1223a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at [6]{Read with BigQuery Storage API,
assert_that}) (10/16)#0 54fc0cf053788b642d07f970c4e0c32b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task CHAIN MapPartition (MapPartition at [2]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/Create/{FlatMap(<lambda at
core.py:3224>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
7bd059c6d49b127436028b4385cffab2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at [6]{Read with BigQuery Storage API,
assert_that}) (11/16)#0 7da5b549474ae5942de3d1d5f839e4e6.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0
90b3a90f579aa0beb954fd906f56fb5b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at [6]{Read with BigQuery Storage API,
assert_that}) (14/16)#0 74a2bd4a768483b2265d029fa6fb43d0.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (12/16)#0
(b1112f8874ae2d4730db5af6c39de26e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [1]Read with BigQuery
Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects))
(12/16)#0 (b1112f8874ae2d4730db5af6c39de26e).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (9/16)#0 (0c9a63ece0610615b8b8faa1f82de830)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (9/16)#0
(a555a61fa83175dbc236e0e929b3a44f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (3/16)#0 (2c1ccbc6d0bff2a7f300c94bb284de71)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (3/16)#0
(2c1ccbc6d0bff2a7f300c94bb284de71).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at [6]{Read with BigQuery Storage API,
assert_that}) (1/16)#0 6edd52c8200acf9f517a16858e7ff8de.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (3/16)#0
(b4a098a545f0e1a48ebf3ffd0a07ec7e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (3/16)#0 (b4a098a545f0e1a48ebf3ffd0a07ec7e).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (7/16)#0 (c3da477ae320bb2bd97098be654d34e9)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (7/16)#0
(c3da477ae320bb2bd97098be654d34e9).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (7/16)#0
(da9a6de6dca43e0810b15dd4d98fb399) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (7/16)#0 (da9a6de6dca43e0810b15dd4d98fb399).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (16/16)#0 (3a59e4a4a63f0a5cc90204672c26c349)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (16/16)#0
(3a59e4a4a63f0a5cc90204672c26c349).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (16/16)#0
(a1af58517564890c980c6d8481ce4426) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (16/16)#0 (a1af58517564890c980c6d8481ce4426).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (5/16)#0 (a5e65b42084e4d67b39b030665b4e244)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (5/16)#0
(a5e65b42084e4d67b39b030665b4e244).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (5/16)#0
(ec8b22f4f959498100bdb5dd576772e2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (2/16)#0 (300423353b6d965d0c024550903b683a)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (2/16)#0
(469167854e12254e0cc8b27b9e001303) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (14/16)#0 (9fa64c44348e768480b552813fbad395)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (14/16)#0
(9fa64c44348e768480b552813fbad395).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (14/16)#0
(388d6f750154a60d219af20174065292) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (10/16)#0 (ed9ced4aa67fa5b30b8a6f8d483e6a77)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (10/16)#0
(ed9ced4aa67fa5b30b8a6f8d483e6a77).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (10/16)#0
(235549dfa7c524d1385c845259636a9f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (10/16)#0 (235549dfa7c524d1385c845259636a9f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (1/16)#0 (12cced425945e052bd59959b9b4d1564)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (1/16)#0
(12cced425945e052bd59959b9b4d1564).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (1/16)#0
(b738f5cc4a46a9f8febc49e266fe777e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (1/16)#0 (b738f5cc4a46a9f8febc49e266fe777e).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (2/16)#0 (3053ef50291789e0ccea9e027f681b06)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (2/16)#0
(3053ef50291789e0ccea9e027f681b06).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (2/16)#0
(ec81ad91bdfc373fb6ee80d4c33194bc) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (2/16)#0 (ec81ad91bdfc373fb6ee80d4c33194bc).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (9/16)#0 (08f50fcfbc37148f92a77018b81fd215)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]assert_that/{Group, Unkey, Match}) (9/16)#0
(31f072379a5285b726dca5ebf07efb34) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (9/16)#0 (31f072379a5285b726dca5ebf07efb34).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.executiongraph.Execution
sendReleaseIntermediateResultPartitionsRpcCall'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Discarding the results produced by task execution
93d4be200dd47d91383be9758e372b9b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (9/16)#0
(08f50fcfbc37148f92a77018b81fd215).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (14/16)#0 (388d6f750154a60d219af20174065292).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.executiongraph.Execution
handlePartitionCleanup'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Discarding the results produced by task execution
93d4be200dd47d91383be9758e372b9b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [1]Read with BigQuery
Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects))
(2/16)#0 (469167854e12254e0cc8b27b9e001303).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (2/16)#0
(300423353b6d965d0c024550903b683a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [4]assert_that/{Group,
Unkey, Match}) (5/16)#0 (ec8b22f4f959498100bdb5dd576772e2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (6/16)#0 (31fcc114db9773eb23bdf388702e694a)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (6/16)#0
(31fcc114db9773eb23bdf388702e694a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (6/16)#0
(5f6fb0793e7fca5e808850a63d04fbbe) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [1]Read with BigQuery
Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects))
(6/16)#0 (5f6fb0793e7fca5e808850a63d04fbbe).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (8/16)#0 (383a5b2d95d429e85cfc08c343014292)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (8/16)#0
(b5e31a8787e67f4dec39515b37b3e993) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [1]Read with BigQuery
Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects))
(8/16)#0 (b5e31a8787e67f4dec39515b37b3e993).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (7/16)#0 (e6d6a39d0265c26a9eef9d0d07df6f86)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (7/16)#0
(e6d6a39d0265c26a9eef9d0d07df6f86).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (7/16)#0
(2a938bca8c2f4a7d6745714fca06258d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (11/16)#0 (444fd0faab3ed984cbf571fc413d6771)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (11/16)#0
(f17348d420c12764b4bade232f813fe6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [1]Read with BigQuery
Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects))
(11/16)#0 (f17348d420c12764b4bade232f813fe6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (14/16)#0
(e89f66a3a56fb03c7f42921b83aca509) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [1]Read with BigQuery
Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects))
(14/16)#0 (e89f66a3a56fb03c7f42921b83aca509).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (14/16)#0 (53677134c0790eb29ca84892dd965709)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task CHAIN MapPartition (MapPartition at [3]Read with BigQuery Storage
API/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap
(FlatMap at ExtractOutput[0]) (9/16)#0 f3322bebac571d6047d66dfe9f257de9.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task CHAIN MapPartition (MapPartition at [3]Read with BigQuery Storage
API/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap
(FlatMap at ExtractOutput[0]) (12/16)#0 5f709fd0e62e82cec5d6f07ce6fa2953.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task CHAIN MapPartition (MapPartition at [4]assert_that/{Create, Group}) ->
FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0
fae8526ce11165f9fd2d4d331e9d352d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task CHAIN MapPartition (MapPartition at [3]Read with BigQuery Storage
API/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap
(FlatMap at ExtractOutput[0]) (8/16)#0 8c307ddf3b2048fc14002251814e68c7.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [1]Read with BigQuery
Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects))
(9/16)#0 (a555a61fa83175dbc236e0e929b3a44f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (9/16)#0
(0c9a63ece0610615b8b8faa1f82de830).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (12/16)#0 (8b224e88b7266836c1a7cc8a0029b688)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (13/16)#0 (0e0b93aa6ff8f43efa53418b63116622)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (12/16)#0
(8b224e88b7266836c1a7cc8a0029b688).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (13/16)#0
(0e0b93aa6ff8f43efa53418b63116622).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task CHAIN MapPartition (MapPartition at [3]Read with BigQuery Storage
API/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap
(FlatMap at ExtractOutput[0]) (14/16)#0 da39f89170757efeef955c8c65d1f12d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (13/16)#0
(3735ce2cbd23dc7f710a27cb6e415a0d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (5/16)#0 (b38c43b75283ba03e02adb81d785493d)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for DataSink (DiscardingOutput) (5/16)#0
(b38c43b75283ba03e02adb81d785493d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]Read with BigQuery Storage
API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (5/16)#0
(548348255a54e6ea2a3fbd3d7c61e28b) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:47 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for MapPartition (MapPartition at [1]Read with BigQuery
Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects))
(5/16)#0 (548348255a54e6ea2a3fbd3d7c61e28b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (3/16)#0 (83d725ffb4df2ee2ec0fe67c2b26a541)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 13,
2021 12:10:46 AM org.apache.flink.runtime.taskmanager.Task transitionState'
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]
