See <https://ci-beam.apache.org/job/beam_PostCommit_Python36/4672/display/redirect>
Changes: ------------------------------------------ [...truncated 50.85 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (9/16)#0 (dd5f491c3c1b69384822c8aee893caf5) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (9/16) (dd5f491c3c1b69384822c8aee893caf5) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup getOrAddOperator' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'WARNING: The operator name MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) exceeded the 80 characters length limit and was truncated.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot b78e449716fd38b51d41cfcc972ebbeb.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (10/16)#0 (216abc5e181706e97007c873be7b5949) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (10/16)#0 (216abc5e181706e97007c873be7b5949) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (10/16)#0 (216abc5e181706e97007c873be7b5949) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (10/16) (216abc5e181706e97007c873be7b5949) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: getProcessBundleDescriptor request with id 1-31' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (10/16)#0 (216abc5e181706e97007c873be7b5949) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup getOrAddOperator' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'WARNING: The operator name MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) exceeded the 80 characters length limit and was truncated.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (10/16) (216abc5e181706e97007c873be7b5949) switched from INITIALIZING to RUNNING.' INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:807 Creating insecure state channel for localhost:41985. INFO apache_beam.runners.worker.sdk_worker:sdk_worker.py:814 State channel established. INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (11/16)#0 (6addb6c0f54a3313b3b755e054450bbb), deploy into slot with allocation id b78e449716fd38b51d41cfcc972ebbeb.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in 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.data_plane:data_plane.py:750 Creating client data channel for localhost:46545 INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 4adf9e058f78b1781ed242bef5a4e9b2.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (12/16)#0 (8aa1e441171c1a0558b6575eb484a04f), deploy into slot with allocation id 4adf9e058f78b1781ed242bef5a4e9b2.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (11/16)#0 (6addb6c0f54a3313b3b755e054450bbb) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (11/16)#0 (6addb6c0f54a3313b3b755e054450bbb) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (11/16)#0 (6addb6c0f54a3313b3b755e054450bbb) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (11/16) (6addb6c0f54a3313b3b755e054450bbb) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (11/16)#0 (6addb6c0f54a3313b3b755e054450bbb) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (11/16) (6addb6c0f54a3313b3b755e054450bbb) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup getOrAddOperator' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'WARNING: The operator name MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) exceeded the 80 characters length limit and was truncated.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (12/16)#0 (8aa1e441171c1a0558b6575eb484a04f) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (12/16)#0 (8aa1e441171c1a0558b6575eb484a04f) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (12/16)#0 (8aa1e441171c1a0558b6575eb484a04f) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 8b3459eb9492001ee9212f0cd675f47d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (12/16) (8aa1e441171c1a0558b6575eb484a04f) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (12/16)#0 (8aa1e441171c1a0558b6575eb484a04f) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (12/16) (8aa1e441171c1a0558b6575eb484a04f) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup getOrAddOperator' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'WARNING: The operator name MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) exceeded the 80 characters length limit and was truncated.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (13/16)#0 (c4eb89bd412545e341f33eaa8cafa5ff), deploy into slot with allocation id 8b3459eb9492001ee9212f0cd675f47d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (13/16)#0 (c4eb89bd412545e341f33eaa8cafa5ff) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot f60b326998cde5297b943c7156d4d506.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (13/16)#0 (c4eb89bd412545e341f33eaa8cafa5ff) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (13/16)#0 (c4eb89bd412545e341f33eaa8cafa5ff) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.runners.fnexecution.data.GrpcDataService data' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Beam Fn Data client connected.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (13/16) (c4eb89bd412545e341f33eaa8cafa5ff) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (13/16)#0 (c4eb89bd412545e341f33eaa8cafa5ff) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup getOrAddOperator' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'WARNING: The operator name MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) exceeded the 80 characters length limit and was truncated.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (14/16)#0 (e74208da0d7e9eb913eb094cc1054cee), deploy into slot with allocation id f60b326998cde5297b943c7156d4d506.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (13/16) (c4eb89bd412545e341f33eaa8cafa5ff) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (14/16)#0 (e74208da0d7e9eb913eb094cc1054cee) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (14/16)#0 (e74208da0d7e9eb913eb094cc1054cee) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (14/16)#0 (e74208da0d7e9eb913eb094cc1054cee) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (14/16)#0 (e74208da0d7e9eb913eb094cc1054cee) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup getOrAddOperator' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'WARNING: The operator name MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) exceeded the 80 characters length limit and was truncated.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (14/16) (e74208da0d7e9eb913eb094cc1054cee) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (14/16) (e74208da0d7e9eb913eb094cc1054cee) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot f45f7ab554bc746f9657ec398c2d5130.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (15/16)#0 (8f323e274877d7d2c8ff45633a2685e3), deploy into slot with allocation id f45f7ab554bc746f9657ec398c2d5130.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 19c43fd99972ce72ef7ee618806d3eab.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (16/16)#0 (f7461d8190b6de4a64a11ea453cc24f4), deploy into slot with allocation id 19c43fd99972ce72ef7ee618806d3eab.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (16/16)#0 (f7461d8190b6de4a64a11ea453cc24f4) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 985a3784174880eb23d851d0050907d5.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (16/16)#0 (f7461d8190b6de4a64a11ea453cc24f4) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task DataSink (DiscardingOutput) (1/16)#0 (d3af30b970c71ce2ebb1b7a170affb81), deploy into slot with allocation id 985a3784174880eb23d851d0050907d5.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (16/16)#0 (f7461d8190b6de4a64a11ea453cc24f4) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (16/16) (f7461d8190b6de4a64a11ea453cc24f4) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (16/16)#0 (f7461d8190b6de4a64a11ea453cc24f4) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (16/16) (f7461d8190b6de4a64a11ea453cc24f4) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: DataSink (DiscardingOutput) (1/16)#0 (d3af30b970c71ce2ebb1b7a170affb81) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot bdf62dce3c1bf813d6bf1dbe4e6f07d8.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task DataSink (DiscardingOutput) (1/16)#0 (d3af30b970c71ce2ebb1b7a170affb81) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task DataSink (DiscardingOutput) (2/16)#0 (3ec7dc737038a91397b8534d2f991d64), deploy into slot with allocation id bdf62dce3c1bf813d6bf1dbe4e6f07d8.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 90a27f0e6ea8194c8b895d13d9daaee7.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task DataSink (DiscardingOutput) (3/16)#0 (39698f50d3dcad65d59312be8fcac566), deploy into slot with allocation id 90a27f0e6ea8194c8b895d13d9daaee7.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: DataSink (DiscardingOutput) (2/16)#0 (3ec7dc737038a91397b8534d2f991d64) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task DataSink (DiscardingOutput) (2/16)#0 (3ec7dc737038a91397b8534d2f991d64) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: DataSink (DiscardingOutput) (3/16)#0 (39698f50d3dcad65d59312be8fcac566) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 33d07cdb9708d92e2e20789d670b2c3d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task DataSink (DiscardingOutput) (3/16)#0 (39698f50d3dcad65d59312be8fcac566) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task DataSink (DiscardingOutput) (4/16)#0 (02543f4f1fada5007f4f4b34b3188cf4), deploy into slot with allocation id 33d07cdb9708d92e2e20789d670b2c3d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: DataSink (DiscardingOutput) (4/16)#0 (02543f4f1fada5007f4f4b34b3188cf4) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 3d256dfcf0235812f9ce398c8f244011.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (15/16)#0 (8f323e274877d7d2c8ff45633a2685e3) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (15/16)#0 (8f323e274877d7d2c8ff45633a2685e3) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task DataSink (DiscardingOutput) (5/16)#0 (54c5d96feec73c83a022b85b80d9eb12), deploy into slot with allocation id 3d256dfcf0235812f9ce398c8f244011.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (15/16)#0 (8f323e274877d7d2c8ff45633a2685e3) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (15/16)#0 (8f323e274877d7d2c8ff45633a2685e3) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task DataSink (DiscardingOutput) (4/16)#0 (02543f4f1fada5007f4f4b34b3188cf4) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (15/16) (8f323e274877d7d2c8ff45633a2685e3) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task DataSink (DiscardingOutput) (4/16)#0 (02543f4f1fada5007f4f4b34b3188cf4) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (15/16) (8f323e274877d7d2c8ff45633a2685e3) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: MapPartition (MapPartition at [1]Read with BigQuery Storage API/_PassThroughThenCleanupTempDatasets/ParDo(CleanUpProjects)) (15/16) (8f323e274877d7d2c8ff45633a2685e3) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: DataSink (DiscardingOutput) (5/16)#0 (54c5d96feec73c83a022b85b80d9eb12) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 156ecc50b0b3b22f524c9ee637e5be33.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Dec 02, 2021 6:12:00 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task DataSink (DiscardingOutput) (6/16)#0 (2f26879a77baec14314f0ecd12222e8e), deploy into slot with allocation id 156ecc50b0b3b22f524c9ee637e5be33.' FAILURE: Build failed with an exception. * What went wrong: GC overhead limit exceeded * 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: [email protected] For additional commands, e-mail: [email protected]
