See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/55/display/redirect>
Changes:
------------------------------------------
[...truncated 62.28 MB...]
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 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [7]{ReadFromBigQuery, Projected, DesiredMonth,
ExtractMean, GlobalMean}) (7/16) (d0d7e8c4663052affbffa2bf60cccf95) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0
(8064a502df4cd5c37d9348614ff69b89), deploy into slot with allocation id
1130c3f8b2a2ab3c34ec38cd9df4f61c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (14/16)#0
(8064a502df4cd5c37d9348614ff69b89) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0
(8064a502df4cd5c37d9348614ff69b89) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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]) (14/16)#0
(8064a502df4cd5c37d9348614ff69b89) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (14/16)#0
(8064a502df4cd5c37d9348614ff69b89) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [7]{ReadFromBigQuery, Projected, DesiredMonth,
ExtractMean, GlobalMean}) (2/16) (1efafbf01d533f08c7334791e63ed064) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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 19,
2022 6:12:35 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 dfb816ad2f7aa07df8fe5afd0a091cc3:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=7}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0
(a249944abb6b2bddbf7053af99650f78), deploy into slot with allocation id
4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (11/16)#0
(a0ee673f9693381e34eefbd0ddfe861d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (11/16)#0
(a0ee673f9693381e34eefbd0ddfe861d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [7]{ReadFromBigQuery, Projected, DesiredMonth,
ExtractMean, GlobalMean}) (12/16) (b61faf9c92aa3fefcc86835ae755f173) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0
(a249944abb6b2bddbf7053af99650f78) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Loading JAR files for task FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0
(a249944abb6b2bddbf7053af99650f78) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 dfb816ad2f7aa07df8fe5afd0a091cc3:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=6}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0
(a249944abb6b2bddbf7053af99650f78) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (11/16)
(a2e546b3edbd3502a6f10a989ed888f8) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0
(a249944abb6b2bddbf7053af99650f78) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (11/16)
(a2e546b3edbd3502a6f10a989ed888f8) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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)
(a0ee673f9693381e34eefbd0ddfe861d) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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)
(a0ee673f9693381e34eefbd0ddfe861d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (10/16)
(80746bd6e0989c2cb50d66bdc75f929d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(f83258934db3213323c5bd34d695ad01), deploy into slot with allocation id
4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (14/16)
(c4acc64800eed03ee6957f3c7e017edf) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (14/16)
(c4acc64800eed03ee6957f3c7e017edf) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (10/16)#0
89f8c569bd5352d89b6dfaacdf9cd678.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (7/16)#0
(f83258934db3213323c5bd34d695ad01) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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]) (14/16)
(8064a502df4cd5c37d9348614ff69b89) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(f83258934db3213323c5bd34d695ad01) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (14/16)#0
(c4acc64800eed03ee6957f3c7e017edf) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (14/16)
(8064a502df4cd5c37d9348614ff69b89) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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[3]) (14/16)#0
(c4acc64800eed03ee6957f3c7e017edf).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (7/16) (a249944abb6b2bddbf7053af99650f78)
switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (7/16) (a249944abb6b2bddbf7053af99650f78)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (7/16)#0
(f83258934db3213323c5bd34d695ad01) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (7/16)#0
(f83258934db3213323c5bd34d695ad01) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (10/16)
(89f8c569bd5352d89b6dfaacdf9cd678) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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 dfb816ad2f7aa07df8fe5afd0a091cc3:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=5}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (7/16) (f83258934db3213323c5bd34d695ad01)
switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (7/16) (f83258934db3213323c5bd34d695ad01)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0
(ca72f4f4b3f35a96c22ca5ede4ccb5f2), deploy into slot with allocation id
b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0
(ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Loading JAR files for task FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0
(ca72f4f4b3f35a96c22ca5ede4ccb5f2) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0
(ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0
(ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (3/16) (ca72f4f4b3f35a96c22ca5ede4ccb5f2)
switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (3/16) (ca72f4f4b3f35a96c22ca5ede4ccb5f2)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0
(d7f0eba8386d231697e3edf04f84964f), deploy into slot with allocation id
b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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[3]) (11/16)#0
a2e546b3edbd3502a6f10a989ed888f8.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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
(d7f0eba8386d231697e3edf04f84964f) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0
(d7f0eba8386d231697e3edf04f84964f) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (11/16)#0
a0ee673f9693381e34eefbd0ddfe861d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (14/16)#0
(8064a502df4cd5c37d9348614ff69b89) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (14/16)#0
(8064a502df4cd5c37d9348614ff69b89).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (11/16)
(a2e546b3edbd3502a6f10a989ed888f8) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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[3]) (14/16)#0
c4acc64800eed03ee6957f3c7e017edf.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0
(a249944abb6b2bddbf7053af99650f78) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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[3]) (7/16)#0
(a249944abb6b2bddbf7053af99650f78).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (14/16)#0
8064a502df4cd5c37d9348614ff69b89.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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)
(a0ee673f9693381e34eefbd0ddfe861d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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[3]) (7/16)#0
a249944abb6b2bddbf7053af99650f78.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 dfb816ad2f7aa07df8fe5afd0a091cc3:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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
(d7f0eba8386d231697e3edf04f84964f) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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
(d7f0eba8386d231697e3edf04f84964f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (14/16)
(c4acc64800eed03ee6957f3c7e017edf) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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]) (14/16)
(8064a502df4cd5c37d9348614ff69b89) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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 dfb816ad2f7aa07df8fe5afd0a091cc3:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=3}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (7/16) (a249944abb6b2bddbf7053af99650f78)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (3/16) (d7f0eba8386d231697e3edf04f84964f)
switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (3/16) (d7f0eba8386d231697e3edf04f84964f)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (7/16)#0
(f83258934db3213323c5bd34d695ad01) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (7/16)#0
(f83258934db3213323c5bd34d695ad01).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (7/16)#0
f83258934db3213323c5bd34d695ad01.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0
(ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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[3]) (3/16)#0
(ca72f4f4b3f35a96c22ca5ede4ccb5f2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (7/16) (f83258934db3213323c5bd34d695ad01)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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[3]) (3/16)#0
ca72f4f4b3f35a96c22ca5ede4ccb5f2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 dfb816ad2f7aa07df8fe5afd0a091cc3:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=2}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
FlatMap (FlatMap at ExtractOutput[3]) (3/16) (ca72f4f4b3f35a96c22ca5ede4ccb5f2)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 19,
2022 6:12:35 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
(d7f0eba8386d231697e3edf04f84964f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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
(d7f0eba8386d231697e3edf04f84964f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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
d7f0eba8386d231697e3edf04f84964f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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]) (3/16) (d7f0eba8386d231697e3edf04f84964f)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:12:35 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 dfb816ad2f7aa07df8fe5afd0a091cc3:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=1}]'
INFO apache_beam.io.gcp.bigquery_tools:bigquery_tools.py:557 Started
BigQuery job: <JobReference
jobId:
'beam_bq_job_EXPORT_BQ_EXPORT_JOB_672d1732-0_1645294354_754'
location: 'US'
projectId:
'apache-beam-testing'>
bq show -j
--format=prettyjson --project_id=apache-beam-testing
beam_bq_job_EXPORT_BQ_EXPORT_JOB_672d1732-0_1645294354_754
INFO root:bigquery_tools.py:625 Job status: RUNNING
> Task :sdks:python:test-suites:portable:py39:flinkExamples
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/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0
ca35161985ab823fb76f12d8aa9bff80.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:11:26 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at [4]{read, months with tornadoes, monthly count})
(15/16) (decfe243ef5641b07bfeaf65f50bbc57) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:11:26 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 CHAIN MapPartition (MapPartition at [3]read/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
d7494e55fc01eeca06eb243ef6696cfc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:11:26 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (14/16) (208022837bfba45b1bbef5f13842a9e6) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:11:26 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (15/16) (1da735d50830467a091f500e3f418651) switched from
RUNNING to FINISHED.'
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]
