You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2022/03/10 12:11:51 UTC
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #123
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/123/display/redirect>
Changes:
------------------------------------------
[...truncated 34.52 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (10/16)#0 (5e712db39fe7d28fbf86f0435ec4b07a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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) (10/16)#0 (5e712db39fe7d28fbf86f0435ec4b07a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (9/16)#0 (7ee6cf76d16d2b0b0c063778501caa28) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (9/16)#0 (7ee6cf76d16d2b0b0c063778501caa28).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (9/16)#0 (9032c63ba7468f8f0aa67d681bad86f3) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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) (9/16)#0 (9032c63ba7468f8f0aa67d681bad86f3).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (10/16)#0 6b710dbc995b1a904a7854906d444a06.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (13/16)#0 (b4d1c1b9030824e70b9cff9501a8de17) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (13/16)#0 (b4d1c1b9030824e70b9cff9501a8de17).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (7e5e29d9d8e943fe5edf5ce64efcfd39) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (7e5e29d9d8e943fe5edf5ce64efcfd39).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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) (10/16)#0 5e712db39fe7d28fbf86f0435ec4b07a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (9/16)#0 7ee6cf76d16d2b0b0c063778501caa28.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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) (9/16)#0 9032c63ba7468f8f0aa67d681bad86f3.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (10/16) (6b710dbc995b1a904a7854906d444a06) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 7e5e29d9d8e943fe5edf5ce64efcfd39.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (13/16)#0 b4d1c1b9030824e70b9cff9501a8de17.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (10/16) (5e712db39fe7d28fbf86f0435ec4b07a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 e89ea90f9994ff41ba1ea71a7d613b5d: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=9}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (1/16)#0 (8242607ab528003e2c5db1b9efaa5f07) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (1/16)#0 (8242607ab528003e2c5db1b9efaa5f07).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (1/16)#0 (7a075df4f2a15a9969d8be306755707f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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) (1/16)#0 (7a075df4f2a15a9969d8be306755707f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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) (1/16)#0 7a075df4f2a15a9969d8be306755707f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (9/16) (7ee6cf76d16d2b0b0c063778501caa28) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (1/16)#0 8242607ab528003e2c5db1b9efaa5f07.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (15/16)#0 (c8fc3dda145ebf667f8333e684d7098f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (1ef5d0c864bf5356d72b12035f798eb9) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (15/16)#0 (c8fc3dda145ebf667f8333e684d7098f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (9/16) (9032c63ba7468f8f0aa67d681bad86f3) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (1ef5d0c864bf5356d72b12035f798eb9).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 e89ea90f9994ff41ba1ea71a7d613b5d: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=8}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (13/16) (7e5e29d9d8e943fe5edf5ce64efcfd39) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (13/16) (b4d1c1b9030824e70b9cff9501a8de17) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 e89ea90f9994ff41ba1ea71a7d613b5d: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=7}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (15/16)#0 c8fc3dda145ebf667f8333e684d7098f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 1ef5d0c864bf5356d72b12035f798eb9.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (1/16) (7a075df4f2a15a9969d8be306755707f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (1/16) (8242607ab528003e2c5db1b9efaa5f07) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 e89ea90f9994ff41ba1ea71a7d613b5d: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=6}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (15/16) (c8fc3dda145ebf667f8333e684d7098f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (15/16) (1ef5d0c864bf5356d72b12035f798eb9) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 e89ea90f9994ff41ba1ea71a7d613b5d: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=5}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (6/16)#0 (d0027df251cb1d434bc0b273b9bee936) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (6/16)#0 (d0027df251cb1d434bc0b273b9bee936).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (a5d8e93ffd8b44e68aff9a2fbf0683e2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (a5d8e93ffd8b44e68aff9a2fbf0683e2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (6/16)#0 d0027df251cb1d434bc0b273b9bee936.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 a5d8e93ffd8b44e68aff9a2fbf0683e2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (6/16) (d0027df251cb1d434bc0b273b9bee936) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (6/16) (a5d8e93ffd8b44e68aff9a2fbf0683e2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 e89ea90f9994ff41ba1ea71a7d613b5d: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=4}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (7/16)#0 (4f809e4c6a99f2d0153585f9b8b70a73) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (7/16)#0 (4f809e4c6a99f2d0153585f9b8b70a73).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (11369a40e812d25ae5b2c711eaa899ae) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (11369a40e812d25ae5b2c711eaa899ae).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 11369a40e812d25ae5b2c711eaa899ae.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (7/16)#0 4f809e4c6a99f2d0153585f9b8b70a73.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (7/16) (11369a40e812d25ae5b2c711eaa899ae) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (7/16) (4f809e4c6a99f2d0153585f9b8b70a73) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (4/16)#0 (4ae62ee3f511ab8523e8ec86cd31612d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (4/16)#0 (4ae62ee3f511ab8523e8ec86cd31612d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 e89ea90f9994ff41ba1ea71a7d613b5d: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=3}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (4/16)#0 4ae62ee3f511ab8523e8ec86cd31612d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (4/16) (4ae62ee3f511ab8523e8ec86cd31612d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (11/16)#0 (d74dd3a54daf774150cbf488ac222a57) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (11/16)#0 (d74dd3a54daf774150cbf488ac222a57).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (56524bc429c7bf15fa59c78135165790) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (56524bc429c7bf15fa59c78135165790).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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]WriteToText/Write/WriteImpl/FinalizeWrite) (11/16)#0 d74dd3a54daf774150cbf488ac222a57.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 56524bc429c7bf15fa59c78135165790.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/FinalizeWrite) (11/16) (d74dd3a54daf774150cbf488ac222a57) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (11/16) (56524bc429c7bf15fa59c78135165790) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 e89ea90f9994ff41ba1ea71a7d613b5d: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=2}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (73b7edb36ccedfe13c3d1dd7a43b73e8) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 (73b7edb36ccedfe13c3d1dd7a43b73e8).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 73b7edb36ccedfe13c3d1dd7a43b73e8.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSink (DiscardingOutput) (4/16) (73b7edb36ccedfe13c3d1dd7a43b73e8) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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 e89ea90f9994ff41ba1ea71a7d613b5d: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]'
INFO apache_beam.io.gcp.gcsio:gcsio.py:575 Finished listing 3 files in 0.05753374099731445 seconds.
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 0 files in 0.04392290115356445 seconds.
INFO apache_beam.io.filebasedsink:filebasedsink.py:303 Starting finalize_write threads with num_shards: 3 (skipped: 0), batches: 1, num_threads: 3
INFO apache_beam.io.filebasedsink:filebasedsink.py:348 Renamed 3 shards in 0.40 seconds.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:09:49 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:43865"'
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.utils.subprocess_server:subprocess_server.py:125 b'capabilities: "beam:coder:custom_window:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'capabilities: "beam:coder:row:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'capabilities: "beam:coder:sharded_key:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'capabilities: "beam:protocol:progress_reporting:v0"'
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-tempr2cjph32/artifactsdlg9af1z/6887eb0754e23a5512076831589626093829f52f56b73d4c486669dd41e19f2c/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'Mar 10, 2022 12:09:49 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.'
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:244 No more requests from control plane
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:245 SDK Harness waiting for in-flight requests to complete
INFO apache_beam.runners.worker.data_plane:data_plane.py:782 Closing all cached grpc data channels.
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:826 Closing all cached gRPC state handlers.
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'Mar 10, 2022 12:09:49 PM org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.SerializingExecutor run'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'SEVERE: Exception while executing runnable org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed@3fb0ff46'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'java.lang.IllegalStateException: call already closed'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.com.google.common.base.Preconditions.checkState(Preconditions.java:510)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:214)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:207)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:395)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.runners.fnexecution.state.GrpcStateService$Inbound.onCompleted(GrpcStateService.java:150)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onHalfClose(ServerCalls.java:273)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.PartialForwardingServerCallListener.onHalfClose(PartialForwardingServerCallListener.java:35)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.ForwardingServerCallListener.onHalfClose(ForwardingServerCallListener.java:23)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onHalfClose(ForwardingServerCallListener.java:40)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.Contexts$ContextualizedServerCallListener.onHalfClose(Contexts.java:86)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:340)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:866)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat org.apache.beam.vendor.grpc.v1p43p2.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'\tat java.lang.Thread.run(Thread.java:748)'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b''
> Task :sdks:python:test-suites:portable:py39:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for MapPartition (MapPartition at [1]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ParDo(PartitionFiles)/ParDo(PartitionFiles)) (11/16)#0 (36e1f0eb6e767bde1a719a0fbcc71b1a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:07:55 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (60c1f98fa38226c6416410439632146a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:07:55 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (60c1f98fa38226c6416410439632146a).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:07:55 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ParDo(PartitionFiles)/ParDo(PartitionFiles)) (11/16)#0 36e1f0eb6e767bde1a719a0fbcc71b1a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:07:55 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'Mar 10, 2022 12:07:55 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 FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 60c1f98fa38226c6416410439632146a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:07:55 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [1]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ParDo(PartitionFiles)/ParDo(PartitionFiles)) (11/16) (36e1f0eb6e767bde1a719a0fbcc71b1a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:07:55 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 ceda483b0aaa5460553996bb0ffa88a4: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=15}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 10, 2022 12:07:55 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'Mar 10, 2022 12:07:55 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (11/16) (222767fe1e39397cd5f5285f2b4ea8a9) switched from CREATED to SCHEDULED.'
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: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Python_Examples_Flink #124
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/124/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org