See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/47/display/redirect?page=changes>
Changes:
[Kenneth Knowles] Disable AfterSynchronizedProcessingTime test on Dataflow
[mmack] [BEAM-13563] Introducing common AWS ClientBuilderFactory to unify
[noreply] Case studies page improvements (#16702)
------------------------------------------
[...truncated 53.50 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=10}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 6-7'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 6-2'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (5/16)#0
(552589130164fa089d4e2fd91f8ac570) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite) (5/16)#0
(552589130164fa089d4e2fd91f8ac570).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (5/16)#0 (7c17207e5d3ab3a0da7ad4e38af84d28)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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
(7c17207e5d3ab3a0da7ad4e38af84d28).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite)
(5/16)#0 552589130164fa089d4e2fd91f8ac570.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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 7c17207e5d3ab3a0da7ad4e38af84d28.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (5/16)
(552589130164fa089d4e2fd91f8ac570) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (5/16) (7c17207e5d3ab3a0da7ad4e38af84d28) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=9}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 6-9'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (12/16)#0
(3f32faa450764c8c03f5ad85295e1734) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite) (12/16)#0
(3f32faa450764c8c03f5ad85295e1734).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (12/16)#0 (7bf74a0f4893e4261a064d0153f63d06)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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
(7bf74a0f4893e4261a064d0153f63d06).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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) (12/16)#0
7bf74a0f4893e4261a064d0153f63d06.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite)
(12/16)#0 3f32faa450764c8c03f5ad85295e1734.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (12/16) (7bf74a0f4893e4261a064d0153f63d06) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (12/16)
(3f32faa450764c8c03f5ad85295e1734) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=8}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (13/16)#0
(d32696df480456ff7af979110724c4b4) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite) (13/16)#0
(d32696df480456ff7af979110724c4b4).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (13/16)#0 (d5547139b1c3cd94ef06f3da7c6eb8b3)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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
(d5547139b1c3cd94ef06f3da7c6eb8b3).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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) (13/16)#0
d5547139b1c3cd94ef06f3da7c6eb8b3.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite)
(13/16)#0 d32696df480456ff7af979110724c4b4.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (13/16) (d5547139b1c3cd94ef06f3da7c6eb8b3) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (13/16)
(d32696df480456ff7af979110724c4b4) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=7}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (3/16)#0
(d2ed6d5019d7e42f0f9d76c93635b4dc) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite) (3/16)#0
(d2ed6d5019d7e42f0f9d76c93635b4dc).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (3/16)#0 (c6ae13b60c42a63c1e9a093eb7e1478b)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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
(c6ae13b60c42a63c1e9a093eb7e1478b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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) (3/16)#0 c6ae13b60c42a63c1e9a093eb7e1478b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite)
(3/16)#0 d2ed6d5019d7e42f0f9d76c93635b4dc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (3/16) (c6ae13b60c42a63c1e9a093eb7e1478b) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (3/16)
(d2ed6d5019d7e42f0f9d76c93635b4dc) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=6}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (7/16)#0
(a778680929cb985048b55eae16c2035f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite) (7/16)#0
(a778680929cb985048b55eae16c2035f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (7/16)#0 (52b028a2d95608e8ad57b91f758b991d)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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
(52b028a2d95608e8ad57b91f758b991d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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) (7/16)#0 52b028a2d95608e8ad57b91f758b991d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite)
(7/16)#0 a778680929cb985048b55eae16c2035f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (7/16) (52b028a2d95608e8ad57b91f758b991d) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (11/16)#0
(a257f8b20bbe0405aafba0f7e3b6dd49) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite) (11/16)#0
(a257f8b20bbe0405aafba0f7e3b6dd49).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (11/16)#0 (569908a3c4971b7ccdcef7276415988b)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (7/16)
(a778680929cb985048b55eae16c2035f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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
(569908a3c4971b7ccdcef7276415988b).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite)
(11/16)#0 a257f8b20bbe0405aafba0f7e3b6dd49.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=5}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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) (11/16)#0
569908a3c4971b7ccdcef7276415988b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (11/16)
(a257f8b20bbe0405aafba0f7e3b6dd49) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (11/16) (569908a3c4971b7ccdcef7276415988b) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (15/16)#0
(cbe54a3306ffc2820a0ff1387b13fd59) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite) (15/16)#0
(cbe54a3306ffc2820a0ff1387b13fd59).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (15/16)#0 (f8096fa08515362c81a3efe98a1c8592)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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
(f8096fa08515362c81a3efe98a1c8592).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (6/16)#0
(0903098f03c920647039808a4f657c1c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite)
(15/16)#0 cbe54a3306ffc2820a0ff1387b13fd59.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (6/16)#0 (95fc45a2fd0835eb4b54bff3a9709246)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite) (6/16)#0
(0903098f03c920647039808a4f657c1c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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
(95fc45a2fd0835eb4b54bff3a9709246).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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) (15/16)#0
f8096fa08515362c81a3efe98a1c8592.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite)
(6/16)#0 0903098f03c920647039808a4f657c1c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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) (6/16)#0 95fc45a2fd0835eb4b54bff3a9709246.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (15/16)
(cbe54a3306ffc2820a0ff1387b13fd59) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (4/16)#0
(0dc2cade49cc5ac040f475666c9875c6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite) (4/16)#0
(0dc2cade49cc5ac040f475666c9875c6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (4/16)#0 (33df981c7b5c93f6416ee2b72fa9007c)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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
(33df981c7b5c93f6416ee2b72fa9007c).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (15/16) (f8096fa08515362c81a3efe98a1c8592) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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]write/Write/WriteImpl/FinalizeWrite)
(4/16)#0 0dc2cade49cc5ac040f475666c9875c6.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=3}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (6/16)
(0903098f03c920647039808a4f657c1c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM 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 33df981c7b5c93f6416ee2b72fa9007c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (6/16) (95fc45a2fd0835eb4b54bff3a9709246) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=2}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [1]write/Write/WriteImpl/FinalizeWrite) (4/16)
(0dc2cade49cc5ac040f475666c9875c6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (4/16) (33df981c7b5c93f6416ee2b72fa9007c) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job 755315a37c1557862506e3d82d26dd40:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=1}]'
INFO apache_beam.io.filebasedsink:filebasedsink.py:348 Renamed 2 shards in
0.11 seconds.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient
unref'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Closing environment urn: "beam:env:external:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'payload: "\\n\\021\\n\\017localhost:43689"'
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"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:double:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:iterable:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:timer:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:interval_window:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:length_prefix:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:global_window:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:windowed_value:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:param_windowed_value:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:state_backed_iterable:v1"'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:244 No more
requests from control plane
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:custom_window:v1"'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:245 SDK Harness
waiting for in-flight requests to complete
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:row:v1"'
ERROR apache_beam.runners.worker.data_plane:data_plane.py:641 Failed to read
inputs in the data plane.
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,>
line 634, in _read_inputs
for elements in elements_iterator:
File
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,>
line 426, in __next__
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,>
line 826, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.CANCELLED
details = "Multiplexer hanging up"
debug_error_string =
"{"created":"@1645128344.913196081","description":"Error received from peer
ipv6:[::1]:35551","file":"src/core/lib/surface/call.cc","file_line":1074,"grpc_message":"Multiplexer
hanging up","grpc_status":1}"
>
INFO apache_beam.runners.worker.data_plane:data_plane.py:782 Closing all
cached grpc data channels.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:sharded_key:v1"'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:826 Closing all
cached gRPC state handlers.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:protocol:progress_reporting:v0"'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:257 Done consuming
work.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:protocol:harness_monitoring_infos:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:protocol:worker_status:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:combinefn:packed_python:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:version:sdk_base:apache/beam_python3.7_sdk:2.38.0.dev"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:transform:sdf_truncate_sized_restrictions:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:transform:to_string:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'dependencies {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
type_urn: "beam:artifact:type:file:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
type_payload:
"\\n\\232\\001/tmp/beam-tempnz882ce0/artifactsn_o4l93z/6a7460ebacabf83dc28efee61d76d03cf3f873042b2238f13181bf2915391bc1/1-ref_Environment_default_e-pickled_main_session"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
role_urn: "beam:artifact:role:staging_to:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'
role_payload: "\\n\\024pickled_main_session"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'}'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b''
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:05:44 PM
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.'
> Task :sdks:python:test-suites:portable:py39:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(d33fba65d792973bfd437314f41b3314) switched from SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.flink.runtime.executiongraph.Execution deploy'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Deploying CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (attempt #0)
with attempt id d33fba65d792973bfd437314f41b3314 to
6a33a760-9ea7-4fd7-91d9-20ade3e4b280 @ localhost (dataPort=-1) with allocation
id c55d5d97c4e2aef76d9343c2a6a37107'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(8e5047d2cef182c27e00d97c229a33f7) switched from SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.flink.runtime.executiongraph.Execution deploy'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Deploying CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (attempt #0)
with attempt id 8e5047d2cef182c27e00d97c229a33f7 to
6a33a760-9ea7-4fd7-91d9-20ade3e4b280 @ localhost (dataPort=-1) with allocation
id e0229df50020f7ea12f264d97193bc0e'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(0b25dca5eb69d5725bd6fd56dc506c2f) switched from SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.flink.runtime.executiongraph.Execution deploy'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Deploying CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (attempt #0)
with attempt id 0b25dca5eb69d5725bd6fd56dc506c2f to
6a33a760-9ea7-4fd7-91d9-20ade3e4b280 @ localhost (dataPort=-1) with allocation
id 5ea601e870838e5cdceeb45d01d96f7b'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (7/16)#0 (fddbc006bbb7db7e8f20924033a6976a) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 17,
2022 8:04:27 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'java.lang.OutOfMemoryError: GC overhead limit exceeded
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]
