See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/117/display/redirect?page=changes>
Changes:
[noreply] [BEAM-10976] Bundle finalization: Harness and some exec changes
(#16980)
------------------------------------------
[...truncated 27.84 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (5/16) (bc67484b6d205ce8d508e0b40ca26fb1) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (10/16)#0
(7f3aa0ff8aa01c387e9dba898de6a2ba) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (10/16)#0
(7f3aa0ff8aa01c387e9dba898de6a2ba).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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 (9588b88994c9131d11cb037a3972b4a6)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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
(9588b88994c9131d11cb037a3972b4a6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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 DataSink (DiscardingOutput) (10/16)#0
9588b88994c9131d11cb037a3972b4a6.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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 [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (10/16)#0
7f3aa0ff8aa01c387e9dba898de6a2ba.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (10/16) (9588b88994c9131d11cb037a3972b4a6) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (10/16)
(7f3aa0ff8aa01c387e9dba898de6a2ba) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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-248'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (7/16)#0 (d58dd30c30baf4b92d26db2032235b22) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(d58dd30c30baf4b92d26db2032235b22).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (7/16)#0 d58dd30c30baf4b92d26db2032235b22.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (7/16) (d58dd30c30baf4b92d26db2032235b22) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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-249'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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-250'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16)#0 (b5673a16254fb24d2bae569fe0769608) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.io.gcp.gcsio:gcsio.py:559 Starting the size estimation of
the input
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0
(b5673a16254fb24d2bae569fe0769608).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (13/16)#0 b5673a16254fb24d2bae569fe0769608.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16) (b5673a16254fb24d2bae569fe0769608) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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-251'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (12/16)#0 (21c4c69bd988025064b6a21fe7ae6cb5) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)#0
(21c4c69bd988025064b6a21fe7ae6cb5).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (12/16)#0 21c4c69bd988025064b6a21fe7ae6cb5.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (12/16) (21c4c69bd988025064b6a21fe7ae6cb5) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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-252'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (10/16)#0 (cea09adf6416998c36ca98002a7ae390) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0
(cea09adf6416998c36ca98002a7ae390).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (10/16)#0 cea09adf6416998c36ca98002a7ae390.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (10/16) (cea09adf6416998c36ca98002a7ae390) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:28 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-253'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (14/16)#0 (486e15c50b785a2958604b19af3b3ac2) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0
(486e15c50b785a2958604b19af3b3ac2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/16)#0 (0b9dda1dde71dc68f16de125d3adf6df) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0
(0b9dda1dde71dc68f16de125d3adf6df).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (2/16)#0 0b9dda1dde71dc68f16de125d3adf6df.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (14/16)#0 486e15c50b785a2958604b19af3b3ac2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/16) (0b9dda1dde71dc68f16de125d3adf6df) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (14/16) (486e15c50b785a2958604b19af3b3ac2) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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-254'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16)#0 (78066c03f3a77611c13693c0770d6326) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0
(78066c03f3a77611c13693c0770d6326).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (16/16)#0 78066c03f3a77611c13693c0770d6326.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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-257'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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-238'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (78066c03f3a77611c13693c0770d6326) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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-255'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16)#0 (0a830ff7954498699902c51a9d3b7d09) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(0a830ff7954498699902c51a9d3b7d09).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16)#0 (043dbf59f63fd18c8b30a2319df590fa) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0
(043dbf59f63fd18c8b30a2319df590fa).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (8/16)#0 0a830ff7954498699902c51a9d3b7d09.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (3/16)#0 043dbf59f63fd18c8b30a2319df590fa.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (0a830ff7954498699902c51a9d3b7d09) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16) (043dbf59f63fd18c8b30a2319df590fa) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (4/16)#0
(08fe3d37c4a3d535dc7f200a5690e980) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (4/16)#0
(08fe3d37c4a3d535dc7f200a5690e980).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 (c2ce2a3156ab5a5a5356449fb50ad2b2)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
(c2ce2a3156ab5a5a5356449fb50ad2b2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (4/16)#0
08fe3d37c4a3d535dc7f200a5690e980.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (4/16)
(08fe3d37c4a3d535dc7f200a5690e980) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 DataSink (DiscardingOutput) (4/16)#0 c2ce2a3156ab5a5a5356449fb50ad2b2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (4/16) (c2ce2a3156ab5a5a5356449fb50ad2b2) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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-256'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (4/16)#0 (9eec90ba9f5197c27a522589bdc9bb60) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0
(9eec90ba9f5197c27a522589bdc9bb60).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (4/16)#0 9eec90ba9f5197c27a522589bdc9bb60.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (4/16) (9eec90ba9f5197c27a522589bdc9bb60) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16)#0 (acdb382365c37ea96b610c397cf4fa0c) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0
(acdb382365c37ea96b610c397cf4fa0c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (15/16)#0 acdb382365c37ea96b610c397cf4fa0c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (acdb382365c37ea96b610c397cf4fa0c) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (9/16)#0 (49d41df112b1445ab315e601af252aed) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0
(49d41df112b1445ab315e601af252aed).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (9/16)#0 49d41df112b1445ab315e601af252aed.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (9/16) (49d41df112b1445ab315e601af252aed) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (16/16)#0
(83d5d0792c7643516235b4eb96f3887f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (16/16)#0
(83d5d0792c7643516235b4eb96f3887f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 (0e24995a0a050bd7dd661b02d2bbe06e)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
(0e24995a0a050bd7dd661b02d2bbe06e).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 DataSink (DiscardingOutput) (16/16)#0
0e24995a0a050bd7dd661b02d2bbe06e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (16/16)#0
83d5d0792c7643516235b4eb96f3887f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (16/16) (0e24995a0a050bd7dd661b02d2bbe06e) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (6/16)#0 (4cd6c5e606f728748b3eb8865da1d97a) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at [1]attach
corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
(4cd6c5e606f728748b3eb8865da1d97a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (16/16)
(83d5d0792c7643516235b4eb96f3887f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]attach corpus) -> FlatMap
(FlatMap at ExtractOutput[0]) (6/16)#0 4cd6c5e606f728748b3eb8865da1d97a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (5/16)#0
(69e71dd4642db9a840aca5623c41f49b) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (5/16)#0
(69e71dd4642db9a840aca5623c41f49b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 (3c6ef48ac1c2eab066af8f34c3c3b590)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
(3c6ef48ac1c2eab066af8f34c3c3b590).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 DataSink (DiscardingOutput) (5/16)#0 3c6ef48ac1c2eab066af8f34c3c3b590.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (4cd6c5e606f728748b3eb8865da1d97a) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (5/16)#0
69e71dd4642db9a840aca5623c41f49b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (5/16) (3c6ef48ac1c2eab066af8f34c3c3b590) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (5/16)
(69e71dd4642db9a840aca5623c41f49b) switched from RUNNING to FINISHED.'
INFO apache_beam.io.gcp.gcsio:gcsio.py:575 Finished listing 1 files in
0.03805208206176758 seconds.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (1/16)#0
(96297170899662e9c6a5a04fb7b6181b) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 (d61eb3bd3a091ecdac9f83679abc64a5)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (1/16)#0
(96297170899662e9c6a5a04fb7b6181b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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
(d61eb3bd3a091ecdac9f83679abc64a5).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 DataSink (DiscardingOutput) (1/16)#0 d61eb3bd3a091ecdac9f83679abc64a5.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 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 [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (1/16)#0
96297170899662e9c6a5a04fb7b6181b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (1/16) (d61eb3bd3a091ecdac9f83679abc64a5) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:29 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]read
corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (1/16)
(96297170899662e9c6a5a04fb7b6181b) switched from RUNNING to FINISHED.'
INFO root:bigquery_tools.py:625 Job status: DONE
INFO apache_beam.io.gcp.gcsio:gcsio.py:559 Starting the size estimation of
the input
INFO apache_beam.io.gcp.gcsio:gcsio.py:575 Finished listing 1 files in
0.03290152549743652 seconds.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:32 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/16)#0 (8feda5c012868870058d385aae072613) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:32 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at
[3]read_words/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader}) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0
(8feda5c012868870058d385aae072613).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:32 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_words/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/16)#0 8feda5c012868870058d385aae072613.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:10:32 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/16) (8feda5c012868870058d385aae072613) switched from
RUNNING to FINISHED.'
> Task :sdks:python:test-suites:portable:py39:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:08:13 AM
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver
onCompleted'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Hanged up for unknown endpoint.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 09,
2022 12:08:13 AM
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient
close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Error cleaning up servers urn: "beam:env:external:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'payload: "\\n\\021\\n\\017localhost:44115"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:bytes:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:string_utf8:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:kv:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:bool:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:varint:v1"'
FAILURE: Build failed with an exception.
* What went wrong:
GC overhead limit exceeded
* Try:
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
* Exception is:
java.lang.OutOfMemoryError: GC overhead limit exceeded
* Get more help at https://help.gradle.org
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]
