See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/54/display/redirect>
Changes: ------------------------------------------ [...truncated 43.79 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 16b5060142ff7d6a0879a4ae9ba8948f.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260), deploy into slot with allocation id 16b5060142ff7d6a0879a4ae9ba8948f.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16) (789cbdebfc397b3ae6c8f4d823f815e1) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16) (789cbdebfc397b3ae6c8f4d823f815e1) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot f15056e0fb01b76f7f5b6f087d8394dc.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86), deploy into slot with allocation id f15056e0fb01b76f7f5b6f087d8394dc.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 363895348a61f30b9e188072b9472d3e.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945), deploy into slot with allocation id 363895348a61f30b9e188072b9472d3e.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (ac30a51fb295eb8137e7f6e3af3b7260) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (ac30a51fb295eb8137e7f6e3af3b7260) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16) (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16) (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 323fa3449161605b954710e172ca768c.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16) (dedd3b64206e415790a4fb730e5a0945) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16) (dedd3b64206e415790a4fb730e5a0945) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329), deploy into slot with allocation id 323fa3449161605b954710e172ca768c.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 49e8b1ce77d524172dcf2a30adafe725.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16) (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16) (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd), deploy into slot with allocation id 49e8b1ce77d524172dcf2a30adafe725.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot f5df66ef5c2b4af05b528c36593c3a19.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490), deploy into slot with allocation id f5df66ef5c2b4af05b528c36593c3a19.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (0f18aee76062a788d454a2df1318cccd) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (0f18aee76062a788d454a2df1318cccd) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot d933b77b6b63f18b6a0bb66c36181825.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389), deploy into slot with allocation id d933b77b6b63f18b6a0bb66c36181825.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16) (1b97beaeda92a1eb7189bde19a3f4490) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16) (1b97beaeda92a1eb7189bde19a3f4490) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 0e426524c366ebd56e8ac9bb69b5fb62.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7), deploy into slot with allocation id 0e426524c366ebd56e8ac9bb69b5fb62.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from RUNNING to FINISHED.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490).' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 6528d9be7896d12f56945fce01406a31.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16) (cd1c1e637706c8b81fb2bcdcf92569b7) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16) (cd1c1e637706c8b81fb2bcdcf92569b7) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (8beb4b1b93a4a732e93528d49b8ab97d), deploy into slot with allocation id 6528d9be7896d12f56945fce01406a31.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState' FAILURE: Build failed with an exception. * What went wrong: Could not receive a message from the daemon. * Try: > Run with --stacktrace option to get the stack trace. > Run with --info or --debug option to get more log output. > Run with --scan to get full insights. * Get more help at https://help.gradle.org Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
