See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/115/display/redirect>
Changes:
------------------------------------------
[...truncated 18.77 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (6/16)#0 (5a19b5ed173bc98f54ec15f9f57c1d81),
deploy into slot with allocation id 4f9b94c5c6f5a80ee64c1445ecab687f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (5/16)#0 (46c3e3196c342a9a8d4b0b1277543351) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (6/16)#0 (5a19b5ed173bc98f54ec15f9f57c1d81) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 88b279ba637eb68231b481b5f4a36e93.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/16) (37abd23bb72a8e36d864d95542fcf766) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (2/16) (attempt #0) with attempt id
37abd23bb72a8e36d864d95542fcf766 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 4d3d27768af0fba2f50bde5a02a9162b'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16) (15943eb8b7ca27f6adefe06339a420ff) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (attempt #0) with attempt id
15943eb8b7ca27f6adefe06339a420ff to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 871d7fe1375e1979efad7144c5176ca5'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 DataSource (Impulse) (6/16)#0
(5a19b5ed173bc98f54ec15f9f57c1d81) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (6/16)#0 (5a19b5ed173bc98f54ec15f9f57c1d81) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (4/16) (aca7bfd50aa8c687323b48ac32c0ce0d) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (6/16)#0 (5a19b5ed173bc98f54ec15f9f57c1d81) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (7/16)#0 (edbf35cf836917d59216ebcacffef107),
deploy into slot with allocation id 88b279ba637eb68231b481b5f4a36e93.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (attempt #0) with attempt id
aca7bfd50aa8c687323b48ac32c0ce0d to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 331613c0ee3bf363018b51242b3c8742'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (5/16) (a9a0ed64aebcffa03a7131dfbebcfe79) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (7/16)#0 (edbf35cf836917d59216ebcacffef107) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot eb5b2087378a27c1fbb415684e3ee5cd.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 DataSource (Impulse) (7/16)#0
(edbf35cf836917d59216ebcacffef107) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (attempt #0) with attempt id
a9a0ed64aebcffa03a7131dfbebcfe79 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 84f78535f6e5403383a74ad1e090c5de'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (8/16)#0 (975e03c106b21468c5040fd479ad9f51),
deploy into slot with allocation id eb5b2087378a27c1fbb415684e3ee5cd.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (7/16)#0 (edbf35cf836917d59216ebcacffef107) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (7/16)#0 (edbf35cf836917d59216ebcacffef107) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (6ea31a66ca695c2ce2b807472a2191eb) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (6/16) (attempt #0) with attempt id
6ea31a66ca695c2ce2b807472a2191eb to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 4f9b94c5c6f5a80ee64c1445ecab687f'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (7/16) (70b89832f68fad72991c181547579b90) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 7582d94487e5d9f947ecff8801540ba0.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (7/16) (attempt #0) with attempt id
70b89832f68fad72991c181547579b90 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 88b279ba637eb68231b481b5f4a36e93'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (011578efc5a21075c109e1011444ae1e) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (8/16)#0 (975e03c106b21468c5040fd479ad9f51) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 DataSource (Impulse) (8/16)#0
(975e03c106b21468c5040fd479ad9f51) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (8/16)#0 (975e03c106b21468c5040fd479ad9f51) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (8/16)#0 (975e03c106b21468c5040fd479ad9f51) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (8/16) (attempt #0) with attempt id
011578efc5a21075c109e1011444ae1e to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id eb5b2087378a27c1fbb415684e3ee5cd'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (9/16) (c89f85491d36439d612adb16a6916414) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (9/16) (attempt #0) with attempt id
c89f85491d36439d612adb16a6916414 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 7582d94487e5d9f947ecff8801540ba0'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (10/16) (5713595ec9c63296b83fe3cd1099a846) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (9/16)#0 (20cc8cc391e987285e7bd338f3985518),
deploy into slot with allocation id 7582d94487e5d9f947ecff8801540ba0.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 1648f3618bf10ee94b00d81b0c8da515.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (10/16)#0
(bddefed2bfba84b8679c55058ade7ae6), deploy into slot with allocation id
1648f3618bf10ee94b00d81b0c8da515.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot af36fa9fe72bba0285496f2afe012914.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (10/16)#0 (bddefed2bfba84b8679c55058ade7ae6) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 DataSource (Impulse) (10/16)#0
(bddefed2bfba84b8679c55058ade7ae6) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (10/16)#0 (bddefed2bfba84b8679c55058ade7ae6) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (10/16)#0 (bddefed2bfba84b8679c55058ade7ae6) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (attempt #0) with attempt id
5713595ec9c63296b83fe3cd1099a846 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 1648f3618bf10ee94b00d81b0c8da515'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (11/16)#0
(b01e1910d07dcca86f76ef87165fb9d7), deploy into slot with allocation id
af36fa9fe72bba0285496f2afe012914.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (9/16)#0 (20cc8cc391e987285e7bd338f3985518) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 DataSource (Impulse) (9/16)#0
(20cc8cc391e987285e7bd338f3985518) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (11/16) (d029dcffc992dc775bb1925492fa8298) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (9/16)#0 (20cc8cc391e987285e7bd338f3985518) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (attempt #0) with attempt id
d029dcffc992dc775bb1925492fa8298 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id af36fa9fe72bba0285496f2afe012914'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (9/16)#0 (20cc8cc391e987285e7bd338f3985518) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (12/16) (27a08b18c34cf82785400e30d3a96d09) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (12/16) (attempt #0) with attempt id
27a08b18c34cf82785400e30d3a96d09 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 70db7f42291a540c3f2ea60c7c0b8a08'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16) (643a3c693978fafc29c13b0aa7bd74f3) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (attempt #0) with attempt id
643a3c693978fafc29c13b0aa7bd74f3 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id e78fb51aa551c772976846b3feea0704'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (14/16) (e0f5697772ba65a422754dc670d2ac90) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (attempt #0) with attempt id
e0f5697772ba65a422754dc670d2ac90 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 1f18179657b0071da568f6467afd0bf3'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (861017c50b8c7b483a671ed01674b0c0) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (attempt #0) with attempt id
861017c50b8c7b483a671ed01674b0c0 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id 30580e287a0b81c97c48c59acf33be60'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [3]ReadInputText/Read/{Map(<lambda at
iobase.py:898>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (f840e64665acc6ed02cecdb937854708) switched from
SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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
[3]ReadInputText/Read/{Map(<lambda at iobase.py:898>), SDFBoundedSourceReader})
-> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (attempt #0) with attempt id
f840e64665acc6ed02cecdb937854708 to 7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @
localhost (dataPort=-1) with allocation id f55584fc41705cb81ac847f7763ca71f'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (11/16)#0 (b01e1910d07dcca86f76ef87165fb9d7) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 70db7f42291a540c3f2ea60c7c0b8a08.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 DataSource (Impulse) (11/16)#0
(b01e1910d07dcca86f76ef87165fb9d7) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (11/16)#0 (b01e1910d07dcca86f76ef87165fb9d7) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{ReadInputText, UserScore}) -> FlatMap
(FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine:
UserScore/ExtractAndSumScore/CombinePerKey(sum)/Group) -> Map (Key Extractor)
(1/16) (f70fed0bfede131e71c28a088b6057de) switched from SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (11/16)#0 (b01e1910d07dcca86f76ef87165fb9d7) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 [4]{ReadInputText, UserScore}) ->
FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine
(GroupCombine at GroupCombine:
UserScore/ExtractAndSumScore/CombinePerKey(sum)/Group) -> Map (Key Extractor)
(1/16) (attempt #0) with attempt id f70fed0bfede131e71c28a088b6057de to
7bbe30f1-0c88-4f30-9d66-bf2d3a816992 @ localhost (dataPort=-1) with allocation
id 87ff94816d529b7684486542e186b004'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (12/16)#0
(f21e4b457b8465d59486a6d5adf208a3), deploy into slot with allocation id
70db7f42291a540c3f2ea60c7c0b8a08.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot e78fb51aa551c772976846b3feea0704.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (12/16)#0 (f21e4b457b8465d59486a6d5adf208a3) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 DataSource (Impulse) (12/16)#0
(f21e4b457b8465d59486a6d5adf208a3) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (12/16)#0 (f21e4b457b8465d59486a6d5adf208a3) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (12/16)#0 (f21e4b457b8465d59486a6d5adf208a3) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (13/16)#0
(40e4d884e2451d0fe6066cb3fc7d04db), deploy into slot with allocation id
e78fb51aa551c772976846b3feea0704.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 1f18179657b0071da568f6467afd0bf3.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (14/16)#0
(e66ff1309890c9fd12474d9bcd9b1c72), deploy into slot with allocation id
1f18179657b0071da568f6467afd0bf3.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (13/16)#0 (40e4d884e2451d0fe6066cb3fc7d04db) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot 30580e287a0b81c97c48c59acf33be60.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 DataSource (Impulse) (13/16)#0
(40e4d884e2451d0fe6066cb3fc7d04db) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (14/16)#0 (e66ff1309890c9fd12474d9bcd9b1c72) switched from
CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 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 DataSource (Impulse) (14/16)#0
(e66ff1309890c9fd12474d9bcd9b1c72) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (13/16)#0 (40e4d884e2451d0fe6066cb3fc7d04db) switched from
DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (15/16)#0
(9051f82368cb7e3d0093db14c2654b7e), deploy into slot with allocation id
30580e287a0b81c97c48c59acf33be60.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils
getItems'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Unable to retrieve the requested metadata.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (13/16)#0 (40e4d884e2451d0fe6066cb3fc7d04db) switched from
INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot f55584fc41705cb81ac847f7763ca71f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory
createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
The AWS S3 Beam extension was included in this build, but the awsRegion flag
was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received task DataSource (Impulse) (16/16)#0
(3f9f67246a6702cfc02f6747a8167240), deploy into slot with allocation id
f55584fc41705cb81ac847f7763ca71f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:09:00 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (14/16)#0 (e66ff1309890c9fd12474d9bcd9b1c72) switched from
DEPLOYING to INITIALIZING.'
> Task :sdks:python:test-suites:portable:py39:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:07:10 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Activate slot d418feb194d9ed720591504d0d55b25b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:07:10 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 DataSink (DiscardingOutput) (8/16)#0
(bb6be26cfacde69cc13f5f17106038de) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 08,
2022 12:07:10 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (8/16)#0 (bb6be26cfacde69cc13f5f17106038de)
switched from DEPLOYING to INITIALIZING.'
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]
