See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/53/display/redirect?page=changes>
Changes:
[noreply] Remove build status from PR (#16902)
------------------------------------------
[...truncated 42.84 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0
(a83f610a2636b6bd70b9baa70a85d192) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
(55d967876f4c8bfce5bc4cf452ccc1f0), deploy into slot with allocation id
a90019b0ac3c6c6c04f7701187a51946.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0
(a83f610a2636b6bd70b9baa70a85d192) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0
(a83f610a2636b6bd70b9baa70a85d192) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(a83f610a2636b6bd70b9baa70a85d192) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0
(a83f610a2636b6bd70b9baa70a85d192) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: The operator name MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 0b28083a9a233b813d3c539cd22208f2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(a91e4df5a96e874d346b4a12f2b14929), deploy into slot with allocation id
0b28083a9a233b813d3c539cd22208f2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
(55d967876f4c8bfce5bc4cf452ccc1f0) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
(55d967876f4c8bfce5bc4cf452ccc1f0) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(a83f610a2636b6bd70b9baa70a85d192) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
(55d967876f4c8bfce5bc4cf452ccc1f0) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
(55d967876f4c8bfce5bc4cf452ccc1f0) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(55d967876f4c8bfce5bc4cf452ccc1f0) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: The operator name MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(55d967876f4c8bfce5bc4cf452ccc1f0) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(a91e4df5a96e874d346b4a12f2b14929) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(a91e4df5a96e874d346b4a12f2b14929) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 464921332467cf84528cfd59df3d006c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(a91e4df5a96e874d346b4a12f2b14929) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(a91e4df5a96e874d346b4a12f2b14929) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)
(a91e4df5a96e874d346b4a12f2b14929) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: The operator name MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(207016277e8be1d39665037b67a8a47c), deploy into slot with allocation id
464921332467cf84528cfd59df3d006c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(207016277e8be1d39665037b67a8a47c) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(207016277e8be1d39665037b67a8a47c) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(207016277e8be1d39665037b67a8a47c) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(207016277e8be1d39665037b67a8a47c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 41c67c8503367177d44c66c14410147e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)
(a91e4df5a96e874d346b4a12f2b14929) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(207016277e8be1d39665037b67a8a47c) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(207016277e8be1d39665037b67a8a47c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: The operator name MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0
(d7a2498ed866c0d3743d0124f01c4c21), deploy into slot with allocation id
41c67c8503367177d44c66c14410147e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM 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.runners.worker.statecache:statecache.py:172 Creating state
cache with size 0
INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:164 Creating
insecure control channel for localhost:44369.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0
(d7a2498ed866c0d3743d0124f01c4c21) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0
(d7a2498ed866c0d3743d0124f01c4c21) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot ffe8fd0f5560a551584329c165ac1250.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0
(d7a2498ed866c0d3743d0124f01c4c21) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0
(d7a2498ed866c0d3743d0124f01c4c21) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(d7a2498ed866c0d3743d0124f01c4c21) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: The operator name MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(d7a2498ed866c0d3743d0124f01c4c21) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0
(c714e392dc330ca8fe2cbf701f75a555), deploy into slot with allocation id
ffe8fd0f5560a551584329c165ac1250.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 2d134ffaf7361c37362e06380939b042.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0
(d11d1c05efd742fa8577e742f16a41b5), deploy into slot with allocation id
2d134ffaf7361c37362e06380939b042.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0
(c714e392dc330ca8fe2cbf701f75a555) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0
(c714e392dc330ca8fe2cbf701f75a555) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0
(c714e392dc330ca8fe2cbf701f75a555) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0
(c714e392dc330ca8fe2cbf701f75a555) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(c714e392dc330ca8fe2cbf701f75a555) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: The operator name MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(c714e392dc330ca8fe2cbf701f75a555) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM 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:16:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot dbf9992d89eab0e920f6d60623ea0fdd.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0
(d11d1c05efd742fa8577e742f16a41b5) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0
(d11d1c05efd742fa8577e742f16a41b5) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0
(d11d1c05efd742fa8577e742f16a41b5) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0
(d11d1c05efd742fa8577e742f16a41b5) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(d11d1c05efd742fa8577e742f16a41b5) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: The operator name MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(d11d1c05efd742fa8577e742f16a41b5) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)#0
(b3d1d5f06e2bb82fff1964784bfc3fcf), deploy into slot with allocation id
dbf9992d89eab0e920f6d60623ea0fdd.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 74dd84e92547765cbc37ddae0a8a9464.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0
(1a69b6914467fc2041c0fe782ac7a0f5), deploy into slot with allocation id
74dd84e92547765cbc37ddae0a8a9464.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM 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:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)#0
(b3d1d5f06e2bb82fff1964784bfc3fcf) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)#0
(b3d1d5f06e2bb82fff1964784bfc3fcf) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)#0
(b3d1d5f06e2bb82fff1964784bfc3fcf) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)#0
(b3d1d5f06e2bb82fff1964784bfc3fcf) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(b3d1d5f06e2bb82fff1964784bfc3fcf) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(b3d1d5f06e2bb82fff1964784bfc3fcf) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: The operator name MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 846de75ad93951444b46cd4d2f3dce7d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0
(7fb528a4f9b55610b77f57227e6ea855), deploy into slot with allocation id
846de75ad93951444b46cd4d2f3dce7d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0
(7fb528a4f9b55610b77f57227e6ea855) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 083b8d234fcf1d2c7d2a590672c7651e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0
(7fb528a4f9b55610b77f57227e6ea855) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0
(7fb528a4f9b55610b77f57227e6ea855) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0
(7fb528a4f9b55610b77f57227e6ea855) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(7fb528a4f9b55610b77f57227e6ea855) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: The operator name MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(7fb528a4f9b55610b77f57227e6ea855) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0
(ab1ecfe845d88bd9c8f873efdd849746), deploy into slot with allocation id
083b8d234fcf1d2c7d2a590672c7651e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0
(1a69b6914467fc2041c0fe782ac7a0f5) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19,
2022 6:16:07 AM 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 [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0
(1a69b6914467fc2041c0fe782ac7a0f5) [DEPLOYING].'
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]
