See <https://ci-beam.apache.org/job/beam_PostCommit_Python36/4513/display/redirect>
Changes: ------------------------------------------ [...truncated 62.71 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: DataSink (DiscardingOutput) (16/16) (dda2607d33fb4701c05d9f1aa3c1c542) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: DataSink (DiscardingOutput) (16/16) (dda2607d33fb4701c05d9f1aa3c1c542) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (6b3e41c3193f7ea4d6f8cc677c68ffcd) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (6b3e41c3193f7ea4d6f8cc677c68ffcd) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (1/16) (6b3e41c3193f7ea4d6f8cc677c68ffcd) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (1/16) (6b3e41c3193f7ea4d6f8cc677c68ffcd) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (5c82b02330179ff5f7afef83c82119c4), deploy into slot with allocation id 03a3cf0a0568a5b8752e182e655ceff7.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (5c82b02330179ff5f7afef83c82119c4) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot d027929a272e8d66420f48b272486097.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (5c82b02330179ff5f7afef83c82119c4) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (5c82b02330179ff5f7afef83c82119c4) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (16a1f8db3829a2c63482aad951c6669a), deploy into slot with allocation id d027929a272e8d66420f48b272486097.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (5c82b02330179ff5f7afef83c82119c4) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16) (5c82b02330179ff5f7afef83c82119c4) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 50903e7b328010f55fbf8a8ede3cf29d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (16a1f8db3829a2c63482aad951c6669a) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (5c8337d1f35da60ceac3f64edd16a7b3), deploy into slot with allocation id 50903e7b328010f55fbf8a8ede3cf29d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (16a1f8db3829a2c63482aad951c6669a) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16) (5c82b02330179ff5f7afef83c82119c4) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (16a1f8db3829a2c63482aad951c6669a) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (16a1f8db3829a2c63482aad951c6669a) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (16a1f8db3829a2c63482aad951c6669a) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (16a1f8db3829a2c63482aad951c6669a) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (5c8337d1f35da60ceac3f64edd16a7b3) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (5c8337d1f35da60ceac3f64edd16a7b3) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 719b27387cad8385a7bc726ccf7d91d9.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (5c8337d1f35da60ceac3f64edd16a7b3) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (5c8337d1f35da60ceac3f64edd16a7b3) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16) (5c8337d1f35da60ceac3f64edd16a7b3) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (5c82b02330179ff5f7afef83c82119c4) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16) (5c8337d1f35da60ceac3f64edd16a7b3) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (5c82b02330179ff5f7afef83c82119c4).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (87570f3ab761126f9fe75661adf10bcb), deploy into slot with allocation id 719b27387cad8385a7bc726ccf7d91d9.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 463e4c2dc673f70b7b2583b1e6711f8c.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (bd6ab1dbb35576d2632dcd34037cee7f), deploy into slot with allocation id 463e4c2dc673f70b7b2583b1e6711f8c.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (87570f3ab761126f9fe75661adf10bcb) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (87570f3ab761126f9fe75661adf10bcb) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (87570f3ab761126f9fe75661adf10bcb) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16) (87570f3ab761126f9fe75661adf10bcb) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (87570f3ab761126f9fe75661adf10bcb) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16) (87570f3ab761126f9fe75661adf10bcb) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (16a1f8db3829a2c63482aad951c6669a) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (16a1f8db3829a2c63482aad951c6669a).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (5c8337d1f35da60ceac3f64edd16a7b3) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (5c8337d1f35da60ceac3f64edd16a7b3).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (bd6ab1dbb35576d2632dcd34037cee7f) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:56 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 83ca604b38a8c93c676335a66379889f.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (e2993a67b2fc97fbf602eaa0458e2053), deploy into slot with allocation id 83ca604b38a8c93c676335a66379889f.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (bd6ab1dbb35576d2632dcd34037cee7f) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (bd6ab1dbb35576d2632dcd34037cee7f) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16) (bd6ab1dbb35576d2632dcd34037cee7f) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (bd6ab1dbb35576d2632dcd34037cee7f) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16) (bd6ab1dbb35576d2632dcd34037cee7f) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (87570f3ab761126f9fe75661adf10bcb) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (87570f3ab761126f9fe75661adf10bcb).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 3381a62d97da33b1fb8b20b62b3cfabe.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (bd6ab1dbb35576d2632dcd34037cee7f) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (bd6ab1dbb35576d2632dcd34037cee7f).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (6844e713e4b75cfe986b9d4772a9229b), deploy into slot with allocation id 3381a62d97da33b1fb8b20b62b3cfabe.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (e2993a67b2fc97fbf602eaa0458e2053) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (e2993a67b2fc97fbf602eaa0458e2053) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (e2993a67b2fc97fbf602eaa0458e2053) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (e2993a67b2fc97fbf602eaa0458e2053) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (e2993a67b2fc97fbf602eaa0458e2053) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (e2993a67b2fc97fbf602eaa0458e2053) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot 4dc438c8176b465574ae80db8092016d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (e2993a67b2fc97fbf602eaa0458e2053) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (e2993a67b2fc97fbf602eaa0458e2053).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (f2740568972b196aaf902b27b5696dfe), deploy into slot with allocation id 4dc438c8176b465574ae80db8092016d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (6844e713e4b75cfe986b9d4772a9229b) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (6844e713e4b75cfe986b9d4772a9229b) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (6844e713e4b75cfe986b9d4772a9229b) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (6844e713e4b75cfe986b9d4772a9229b) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16) (6844e713e4b75cfe986b9d4772a9229b) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16) (6844e713e4b75cfe986b9d4772a9229b) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (f2740568972b196aaf902b27b5696dfe) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (f2740568972b196aaf902b27b5696dfe) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (f2740568972b196aaf902b27b5696dfe) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (f2740568972b196aaf902b27b5696dfe) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16) (f2740568972b196aaf902b27b5696dfe) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Activate slot fab55746fa3c59232360861bff8498b6.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16) (f2740568972b196aaf902b27b5696dfe) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (e437a59464a55ecb659373ad0872af07), deploy into slot with allocation id fab55746fa3c59232360861bff8498b6.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (6844e713e4b75cfe986b9d4772a9229b) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (6844e713e4b75cfe986b9d4772a9229b).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM 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'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (f2740568972b196aaf902b27b5696dfe) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 23, 2021 12:10:57 PM org.apache.flink.runtime.taskmanager.Task doRun' 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]
