See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/56/display/redirect>
Changes:
------------------------------------------
[...truncated 26.50 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (12/16) (6091a404cdd701e1894534d892fef93b) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 2-2'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 2-5'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 2-4'
INFO apache_beam.runners.worker.data_plane:data_plane.py:750 Creating
client data channel for localhost:42863
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d), deploy into
slot with allocation id 8ddebcf9d74c5b06e332324ffad47979.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 0371e71310364be317d1e49911c6b910.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (89d0d2730735876ed57f129f5585158d) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (89d0d2730735876ed57f129f5585158d) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 2-6'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.beam.runners.fnexecution.data.GrpcDataService data'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Beam Fn Data client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 2-7'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727), deploy into slot
with allocation id 0371e71310364be317d1e49911c6b910.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 2-8'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot c664e6c8579a76e7d26e854dc9262b89.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16) (c1769b4ac895aea26149c25d1059b727) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16) (c1769b4ac895aea26149c25d1059b727) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69), deploy into
slot with allocation id c664e6c8579a76e7d26e854dc9262b89.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 4bac63ee3ff94b2b5dd36930fa5966fe.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f), deploy into slot
with allocation id 4bac63ee3ff94b2b5dd36930fa5966fe.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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
[2]WriteToText/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0
39a4d9b16c66ce5ca50ae5d50f38f217.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (53e993114e7a84d7dc4da4bccbece64f) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (53e993114e7a84d7dc4da4bccbece64f) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot ded7ad69741b809eee2c0614e8baa30e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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]WriteToText/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(39a4d9b16c66ce5ca50ae5d50f38f217) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 817ad3a4134488a929dbf930e6e6f6b7:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=15}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (4/16) (6e187d686a1f35e849e58a24e91751c8) switched from
CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 817ad3a4134488a929dbf930e6e6f6b7:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=16}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838), deploy into
slot with allocation id ded7ad69741b809eee2c0614e8baa30e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (4/16) (6e187d686a1f35e849e58a24e91751c8) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 892c7f70d71bdb94fc978913b1d6cb58.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (4/16) (attempt #0) with attempt id
6e187d686a1f35e849e58a24e91751c8 to a42372b1-2ceb-4f9b-b831-1ba68f3f6052 @
localhost (dataPort=-1) with allocation id d0415eb8a947590a059d030c7f809d6e'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (11/16) (f96293a2cbbd4a9f2abffc21f9220838) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (11/16) (f96293a2cbbd4a9f2abffc21f9220838) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 2-9'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c), deploy into
slot with allocation id 892c7f70d71bdb94fc978913b1d6cb58.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot acb6d9d2f227d56877add69a97db859e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16) (a79c93ca990ccd2416d40c4966cf560c) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff), deploy into
slot with allocation id acb6d9d2f227d56877add69a97db859e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 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 2-10'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/16)#0 (6862273f8007ee2b8d4d2e4216c3e88d) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/16)#0 (6862273f8007ee2b8d4d2e4216c3e88d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 6f26bb44b8fe7ffac105caca1265b061.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (5/16)#0 (0ba9fd428139031e6fa790abb36841f7), deploy into slot
with allocation id 6f26bb44b8fe7ffac105caca1265b061.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16) (a79c93ca990ccd2416d40c4966cf560c) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 2-11'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 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 2-12'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at
ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21,
2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
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]
