You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2022/02/18 18:21:56 UTC
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #51
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/51/display/redirect>
Changes:
------------------------------------------
[...truncated 73.49 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PCOLLECTION": "ref_PCollection_PCollection_52"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-FlatMap-lamb_106"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:data_channel:read_index:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "fn/read/ref_PCollection_PCollection_76:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-FlatMap-lamb_106"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:element_count:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PCOLLECTION": "ref_PCollection_PCollection_76"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "fn/write/ref_PCollection_PCollection_78:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:element_count:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PCOLLECTION": "ref_PCollection_PCollection_78"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:element_count:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PCOLLECTION": "ref_PCollection_PCollection_77"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-Map-decode-_108"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "fn/read/ref_PCollection_PCollection_76:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-Map-decode-_108"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:process_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "fn/read/ref_PCollection_PCollection_76:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:finish_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "fn/write/ref_PCollection_PCollection_78:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "fn/write/ref_PCollection_PCollection_78:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "fn/read/ref_PCollection_PCollection_76:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-FlatMap-lamb_106"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-Map-decode-_108"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:ptransform_execution_time:total_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "fn/write/ref_PCollection_PCollection_78:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "fn/read/ref_PCollection_PCollection_76:0"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-Map-decode-_108"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:pardo_execution_time:start_bundle_msecs:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:sum_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AA==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PTRANSFORM": "ref_AppliedPTransform_SaveToBQ-BigQueryBatchFileLoads-ImpulseMonitorDestinationLoadJobs-FlatMap-lamb_106"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AQ4ODg==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PCOLLECTION": "ref_PCollection_PCollection_77"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AQ4ODg==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PCOLLECTION": "ref_PCollection_PCollection_78"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }, {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "urn": "beam:metric:sampled_byte_size:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "type": "beam:metrics:distribution_int64:v1",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "payload": "AQ0NDQ==",'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "labels": {'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' "PCOLLECTION": "ref_PCollection_PCollection_76"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b' }'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'}'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FileChannelManager removed spill file directory /tmp/flink-io-84578ae0-8482-4a67-8e7d-97415f306b62'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.io.network.NettyShuffleEnvironment close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Shutting down the network environment and its components.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.io.disk.FileChannelManagerImpl lambda$getFileCloser$0'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-b27012eb-9e5d-44a8-b3f4-2293e61d9f25'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.taskexecutor.KvStateService shutdown'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Shutting down the kvState service and its components.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService stop'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Stop job leader service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.filecache.FileCache shutdown'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: removed file cache directory /tmp/flink-dist-cache-7d2b8107-9935-4e90-8240-82fd245a6bee'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.taskexecutor.TaskExecutor handleOnStopException'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Stopped TaskExecutor akka://flink/user/rpc/taskmanager_0.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Stopping Akka RPC service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService stopService'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Stopping Akka RPC service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$8'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Stopped Akka RPC service.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Shutting down BLOB cache'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.blob.AbstractBlobCache close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Shutting down BLOB cache'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.blob.BlobServer close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Stopped BLOB server at 0.0.0.0:40471'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:19:54 PM org.apache.flink.runtime.rpc.akka.AkkaRpcService lambda$stopService$8'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Stopped Akka RPC service.'
PASSED [ 73%]
apache_beam/examples/cookbook/group_with_coder_test.py::GroupWithCoderTest::test_basics_with_type_check
-------------------------------- live log call ---------------------------------
INFO root:pipeline.py:185 Missing pipeline option (runner). Executing pipeline using the default runner: DirectRunner.
> Task :sdks:python:test-suites:portable:py37:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]Write/BigQueryBatchFileLoads/WaitForTempTableLoadJobs) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16) (d92853cc00ea103d7b70c6f6903d7c0c) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]Write/BigQueryBatchFileLoads/WaitForTempTableLoadJobs) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (d92853cc00ea103d7b70c6f6903d7c0c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]Write/BigQueryBatchFileLoads/WaitForTempTableLoadJobs) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16) (d92853cc00ea103d7b70c6f6903d7c0c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM 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 [1]Write/BigQueryBatchFileLoads/WaitForTempTableLoadJobs) exceeded the 80 characters length limit and was truncated.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]Write/BigQueryBatchFileLoads/WaitForTempTableLoadJobs) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (0996eb6bfb35b85fc81d725f72c5f434), deploy into slot with allocation id 592bc91b9e92719ba0891dcea1e0a29a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]Write/BigQueryBatchFileLoads/WaitForTempTableLoadJobs) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (0996eb6bfb35b85fc81d725f72c5f434) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 18575d4df6ec6366a38c1651519d2574.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]Write/BigQueryBatchFileLoads/WaitForTempTableLoadJobs) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (0996eb6bfb35b85fc81d725f72c5f434) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18, 2022 6:18:32 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]Write/BigQueryBatchFileLoads/WaitForTempTableLoadJobs) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (0996eb6bfb35b85fc81d725f72c5f434) switched from DEPLOYING to INITIALIZING.'
FAILURE: Build failed with an exception.
* What went wrong:
GC overhead limit exceeded
* Try:
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
* Exception is:
java.lang.OutOfMemoryError: GC overhead limit exceeded
* Get more help at https://help.gradle.org
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Python_Examples_Flink #57
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/57/display/redirect>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #56
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/56/display/redirect>
Changes:
------------------------------------------
[...truncated 26.50 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16) (6091a404cdd701e1894534d892fef93b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-2'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-5'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-4'
INFO apache_beam.runners.worker.data_plane:data_plane.py:750 Creating client data channel for localhost:42863
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d), deploy into slot with allocation id 8ddebcf9d74c5b06e332324ffad47979.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 0371e71310364be317d1e49911c6b910.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (89d0d2730735876ed57f129f5585158d) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (89d0d2730735876ed57f129f5585158d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-6'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.data.GrpcDataService data'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Beam Fn Data client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-7'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727), deploy into slot with allocation id 0371e71310364be317d1e49911c6b910.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-8'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot c664e6c8579a76e7d26e854dc9262b89.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (c1769b4ac895aea26149c25d1059b727) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (c1769b4ac895aea26149c25d1059b727) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69), deploy into slot with allocation id c664e6c8579a76e7d26e854dc9262b89.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 4bac63ee3ff94b2b5dd36930fa5966fe.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f), deploy into slot with allocation id 4bac63ee3ff94b2b5dd36930fa5966fe.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [2]WriteToText/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 39a4d9b16c66ce5ca50ae5d50f38f217.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16) (53e993114e7a84d7dc4da4bccbece64f) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16) (53e993114e7a84d7dc4da4bccbece64f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot ded7ad69741b809eee2c0614e8baa30e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [2]WriteToText/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (39a4d9b16c66ce5ca50ae5d50f38f217) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job 817ad3a4134488a929dbf930e6e6f6b7: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=15}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (6e187d686a1f35e849e58a24e91751c8) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job 817ad3a4134488a929dbf930e6e6f6b7: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=16}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838), deploy into slot with allocation id ded7ad69741b809eee2c0614e8baa30e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (6e187d686a1f35e849e58a24e91751c8) switched from SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 892c7f70d71bdb94fc978913b1d6cb58.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution deploy'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Deploying CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (attempt #0) with attempt id 6e187d686a1f35e849e58a24e91751c8 to a42372b1-2ceb-4f9b-b831-1ba68f3f6052 @ localhost (dataPort=-1) with allocation id d0415eb8a947590a059d030c7f809d6e'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (f96293a2cbbd4a9f2abffc21f9220838) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (f96293a2cbbd4a9f2abffc21f9220838) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-9'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c), deploy into slot with allocation id 892c7f70d71bdb94fc978913b1d6cb58.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot acb6d9d2f227d56877add69a97db859e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (a79c93ca990ccd2416d40c4966cf560c) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff), deploy into slot with allocation id acb6d9d2f227d56877add69a97db859e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-10'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (6862273f8007ee2b8d4d2e4216c3e88d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (6862273f8007ee2b8d4d2e4216c3e88d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 6f26bb44b8fe7ffac105caca1265b061.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (0ba9fd428139031e6fa790abb36841f7), deploy into slot with allocation id 6f26bb44b8fe7ffac105caca1265b061.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (a79c93ca990ccd2416d40c4966cf560c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-11'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-12'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
java.lang.OutOfMemoryError: GC overhead limit exceeded
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #55
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/55/display/redirect>
Changes:
------------------------------------------
[...truncated 62.28 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [7]{ReadFromBigQuery, Projected, DesiredMonth, ExtractMean, GlobalMean}) (7/16) (d0d7e8c4663052affbffa2bf60cccf95) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89), deploy into slot with allocation id 1130c3f8b2a2ab3c34ec38cd9df4f61c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [7]{ReadFromBigQuery, Projected, DesiredMonth, ExtractMean, GlobalMean}) (2/16) (1efafbf01d533f08c7334791e63ed064) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=7}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78), deploy into slot with allocation id 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (a0ee673f9693381e34eefbd0ddfe861d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (a0ee673f9693381e34eefbd0ddfe861d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [7]{ReadFromBigQuery, Projected, DesiredMonth, ExtractMean, GlobalMean}) (12/16) (b61faf9c92aa3fefcc86835ae755f173) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=6}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (11/16) (a2e546b3edbd3502a6f10a989ed888f8) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (11/16) (a2e546b3edbd3502a6f10a989ed888f8) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (11/16) (a0ee673f9693381e34eefbd0ddfe861d) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (11/16) (a0ee673f9693381e34eefbd0ddfe861d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (10/16) (80746bd6e0989c2cb50d66bdc75f929d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01), deploy into slot with allocation id 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (14/16) (c4acc64800eed03ee6957f3c7e017edf) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (14/16) (c4acc64800eed03ee6957f3c7e017edf) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 89f8c569bd5352d89b6dfaacdf9cd678.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16) (8064a502df4cd5c37d9348614ff69b89) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (14/16)#0 (c4acc64800eed03ee6957f3c7e017edf) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16) (8064a502df4cd5c37d9348614ff69b89) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[3]) (14/16)#0 (c4acc64800eed03ee6957f3c7e017edf).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16) (a249944abb6b2bddbf7053af99650f78) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16) (a249944abb6b2bddbf7053af99650f78) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16) (89f8c569bd5352d89b6dfaacdf9cd678) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=5}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (f83258934db3213323c5bd34d695ad01) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (f83258934db3213323c5bd34d695ad01) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2), deploy into slot with allocation id b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16) (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16) (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f), deploy into slot with allocation id b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[3]) (11/16)#0 a2e546b3edbd3502a6f10a989ed888f8.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 a0ee673f9693381e34eefbd0ddfe861d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (11/16) (a2e546b3edbd3502a6f10a989ed888f8) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[3]) (14/16)#0 c4acc64800eed03ee6957f3c7e017edf.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 8064a502df4cd5c37d9348614ff69b89.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (11/16) (a0ee673f9693381e34eefbd0ddfe861d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 a249944abb6b2bddbf7053af99650f78.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=4}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (14/16) (c4acc64800eed03ee6957f3c7e017edf) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16) (8064a502df4cd5c37d9348614ff69b89) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=3}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16) (a249944abb6b2bddbf7053af99650f78) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (d7f0eba8386d231697e3edf04f84964f) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (d7f0eba8386d231697e3edf04f84964f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 f83258934db3213323c5bd34d695ad01.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (f83258934db3213323c5bd34d695ad01) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 ca72f4f4b3f35a96c22ca5ede4ccb5f2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=2}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16) (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 d7f0eba8386d231697e3edf04f84964f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (d7f0eba8386d231697e3edf04f84964f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]'
INFO apache_beam.io.gcp.bigquery_tools:bigquery_tools.py:557 Started BigQuery job: <JobReference
jobId: 'beam_bq_job_EXPORT_BQ_EXPORT_JOB_672d1732-0_1645294354_754'
location: 'US'
projectId: 'apache-beam-testing'>
bq show -j --format=prettyjson --project_id=apache-beam-testing beam_bq_job_EXPORT_BQ_EXPORT_JOB_672d1732-0_1645294354_754
INFO root:bigquery_tools.py:625 Job status: RUNNING
> Task :sdks:python:test-suites:portable:py39:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]read/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 ca35161985ab823fb76f12d8aa9bff80.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:11:26 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [4]{read, months with tornadoes, monthly count}) (15/16) (decfe243ef5641b07bfeaf65f50bbc57) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:11:26 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]read/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 d7494e55fc01eeca06eb243ef6696cfc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:11:26 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (14/16) (208022837bfba45b1bbef5f13842a9e6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:11:26 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (15/16) (1da735d50830467a091f500e3f418651) switched from RUNNING to FINISHED.'
java.lang.OutOfMemoryError: GC overhead limit exceeded
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #54
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/54/display/redirect>
Changes:
------------------------------------------
[...truncated 43.79 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 16b5060142ff7d6a0879a4ae9ba8948f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260), deploy into slot with allocation id 16b5060142ff7d6a0879a4ae9ba8948f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16) (789cbdebfc397b3ae6c8f4d823f815e1) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16) (789cbdebfc397b3ae6c8f4d823f815e1) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot f15056e0fb01b76f7f5b6f087d8394dc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86), deploy into slot with allocation id f15056e0fb01b76f7f5b6f087d8394dc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 363895348a61f30b9e188072b9472d3e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945), deploy into slot with allocation id 363895348a61f30b9e188072b9472d3e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (ac30a51fb295eb8137e7f6e3af3b7260) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (ac30a51fb295eb8137e7f6e3af3b7260) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16) (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16) (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 323fa3449161605b954710e172ca768c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16) (dedd3b64206e415790a4fb730e5a0945) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16) (dedd3b64206e415790a4fb730e5a0945) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329), deploy into slot with allocation id 323fa3449161605b954710e172ca768c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 49e8b1ce77d524172dcf2a30adafe725.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16) (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16) (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd), deploy into slot with allocation id 49e8b1ce77d524172dcf2a30adafe725.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot f5df66ef5c2b4af05b528c36593c3a19.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490), deploy into slot with allocation id f5df66ef5c2b4af05b528c36593c3a19.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (0f18aee76062a788d454a2df1318cccd) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (0f18aee76062a788d454a2df1318cccd) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot d933b77b6b63f18b6a0bb66c36181825.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389), deploy into slot with allocation id d933b77b6b63f18b6a0bb66c36181825.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16) (1b97beaeda92a1eb7189bde19a3f4490) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16) (1b97beaeda92a1eb7189bde19a3f4490) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 0e426524c366ebd56e8ac9bb69b5fb62.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7), deploy into slot with allocation id 0e426524c366ebd56e8ac9bb69b5fb62.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 6528d9be7896d12f56945fce01406a31.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16) (cd1c1e637706c8b81fb2bcdcf92569b7) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16) (cd1c1e637706c8b81fb2bcdcf92569b7) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (8beb4b1b93a4a732e93528d49b8ab97d), deploy into slot with allocation id 6528d9be7896d12f56945fce01406a31.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
FAILURE: Build failed with an exception.
* What went wrong:
Could not receive a message from the daemon.
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #53
Posted by Apache Jenkins Server <je...@builds.apache.org>.
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: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #52
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/52/display/redirect?page=changes>
Changes:
[rogelio.hernandez] [BEAM-13051] Pylint misplaced-bare-raise warning enabled
[rogelio.hernandez] [BEAM-13051] Added descriptions to Kinesis and PortableRunner exceptions
[thiagotnunes] fix: fix bug when retrieving either string or json
[noreply] [BEAM-13812] Integrate DataprocClusterManager into Interactive
[noreply] [BEAM-12572] Fix failing python examples tests in Dataflow runner
------------------------------------------
[...truncated 35.50 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 29755d5fdf79a6e6fcee5b23d531e39c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16)#0 (25a3cdf4ff7bae56596724945457b0b2) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310), deploy into slot with allocation id 29755d5fdf79a6e6fcee5b23d531e39c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16)#0 (25a3cdf4ff7bae56596724945457b0b2) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot be0714a7452dc2c901bced8927ec6997.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16)#0 (25a3cdf4ff7bae56596724945457b0b2) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16)#0 (25a3cdf4ff7bae56596724945457b0b2) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16) (25a3cdf4ff7bae56596724945457b0b2) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16) (25a3cdf4ff7bae56596724945457b0b2) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16) (ad382f6b00eafce1b34691ca1593a310) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16) (ad382f6b00eafce1b34691ca1593a310) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8), deploy into slot with allocation id be0714a7452dc2c901bced8927ec6997.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 76055b893ca3a378688b9caeab379cc1.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b), deploy into slot with allocation id 76055b893ca3a378688b9caeab379cc1.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 90c82c29243a73ef9418e6fa967454f9.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 3-63'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9), deploy into slot with allocation id 90c82c29243a73ef9418e6fa967454f9.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 3-64'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16) (865a98faed09974ef21bc50b7c2fc35b) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16) (bc75f08179efb3fda2dad60fb5e299a8) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16) (865a98faed09974ef21bc50b7c2fc35b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16) (bc75f08179efb3fda2dad60fb5e299a8) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot ac31ed4754194618a1453d17fcee0d34.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be), deploy into slot with allocation id ac31ed4754194618a1453d17fcee0d34.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot bbfe2d63c0f7cf84c959229b2dcb57d7.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16) (55f9f6b3492f3f731838d001eeed65c9) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16) (55f9f6b3492f3f731838d001eeed65c9) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16) (7777c0be01dae85805dc579fa0e4c5be) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16) (7777c0be01dae85805dc579fa0e4c5be) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb), deploy into slot with allocation id bbfe2d63c0f7cf84c959229b2dcb57d7.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 1173d1b53219134b1d8b787757e90972.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16) (1a55c8cdeae550c7daabd5f8d237a2eb) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16) (1a55c8cdeae550c7daabd5f8d237a2eb) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 3-65'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8), deploy into slot with allocation id 1173d1b53219134b1d8b787757e90972.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot bbd5ce5d6beb6f451f6238e55cd41bde.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16) (56295ed644767f45971224c99d513ad8) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16) (56295ed644767f45971224c99d513ad8) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719), deploy into slot with allocation id bbd5ce5d6beb6f451f6238e55cd41bde.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot f7b6b4434bd33776092962b4075299c2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16) (26d0caf33f7d801baa71640450f00719) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf), deploy into slot with allocation id f7b6b4434bd33776092962b4075299c2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16) (26d0caf33f7d801baa71640450f00719) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 7a719ba16cb6a04e23c424914dc7097d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16) (f36c018a309d70b2e3ae448ae550aabf) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16) (f36c018a309d70b2e3ae448ae550aabf) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 [1]WriteUserScoreSums/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (3a2e2dc248de2d0e0f02602a3c0f8f7c), deploy into slot with allocation id 7a719ba16cb6a04e23c424914dc7097d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 12:08:51 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 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteUserScoreSums/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (3a2e2dc248de2d0e0f02602a3c0f8f7c) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot d7b8644e35a70ed20e5103f66770d4ce.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 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 [1]WriteUserScoreSums/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (3a2e2dc248de2d0e0f02602a3c0f8f7c) [DEPLOYING].'
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org