You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2022/02/19 12:45:52 UTC
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #54
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/54/display/redirect>
Changes:
------------------------------------------
[...truncated 43.79 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 16b5060142ff7d6a0879a4ae9ba8948f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260), deploy into slot with allocation id 16b5060142ff7d6a0879a4ae9ba8948f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16) (789cbdebfc397b3ae6c8f4d823f815e1) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16) (789cbdebfc397b3ae6c8f4d823f815e1) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot f15056e0fb01b76f7f5b6f087d8394dc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86), deploy into slot with allocation id f15056e0fb01b76f7f5b6f087d8394dc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 363895348a61f30b9e188072b9472d3e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945), deploy into slot with allocation id 363895348a61f30b9e188072b9472d3e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (ac30a51fb295eb8137e7f6e3af3b7260) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (789cbdebfc397b3ae6c8f4d823f815e1).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (ac30a51fb295eb8137e7f6e3af3b7260) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16) (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16) (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 323fa3449161605b954710e172ca768c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (ac30a51fb295eb8137e7f6e3af3b7260).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16) (dedd3b64206e415790a4fb730e5a0945) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16) (dedd3b64206e415790a4fb730e5a0945) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329), deploy into slot with allocation id 323fa3449161605b954710e172ca768c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 (d9e510d53b8fa7b49c4ea95d9aa3aa86).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 49e8b1ce77d524172dcf2a30adafe725.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16) (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16) (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (dedd3b64206e415790a4fb730e5a0945).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd), deploy into slot with allocation id 49e8b1ce77d524172dcf2a30adafe725.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 (bbbb789b7cfa5ec5c90aec4ce6c1e329).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot f5df66ef5c2b4af05b528c36593c3a19.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490), deploy into slot with allocation id f5df66ef5c2b4af05b528c36593c3a19.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (0f18aee76062a788d454a2df1318cccd) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (0f18aee76062a788d454a2df1318cccd) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot d933b77b6b63f18b6a0bb66c36181825.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389), deploy into slot with allocation id d933b77b6b63f18b6a0bb66c36181825.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (0f18aee76062a788d454a2df1318cccd).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16) (1b97beaeda92a1eb7189bde19a3f4490) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16) (1b97beaeda92a1eb7189bde19a3f4490) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 0e426524c366ebd56e8ac9bb69b5fb62.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7), deploy into slot with allocation id 0e426524c366ebd56e8ac9bb69b5fb62.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (1b97beaeda92a1eb7189bde19a3f4490).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 6528d9be7896d12f56945fce01406a31.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 (cd1c1e637706c8b81fb2bcdcf92569b7) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16) (cd1c1e637706c8b81fb2bcdcf92569b7) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16) (cd1c1e637706c8b81fb2bcdcf92569b7) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (8beb4b1b93a4a732e93528d49b8ab97d), deploy into slot with allocation id 6528d9be7896d12f56945fce01406a31.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0 (a3bd7bfcfca155ce18bb201a39f5c389) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:09:57 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
FAILURE: Build failed with an exception.
* What went wrong:
Could not receive a message from the daemon.
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Python_Examples_Flink #57
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/57/display/redirect>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #56
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/56/display/redirect>
Changes:
------------------------------------------
[...truncated 26.50 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16) (6091a404cdd701e1894534d892fef93b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-2'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-5'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-4'
INFO apache_beam.runners.worker.data_plane:data_plane.py:750 Creating client data channel for localhost:42863
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d), deploy into slot with allocation id 8ddebcf9d74c5b06e332324ffad47979.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 0371e71310364be317d1e49911c6b910.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (89d0d2730735876ed57f129f5585158d) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (89d0d2730735876ed57f129f5585158d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-6'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.data.GrpcDataService data'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Beam Fn Data client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-7'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727), deploy into slot with allocation id 0371e71310364be317d1e49911c6b910.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-8'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot c664e6c8579a76e7d26e854dc9262b89.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (c1769b4ac895aea26149c25d1059b727) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (c1769b4ac895aea26149c25d1059b727) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (c1769b4ac895aea26149c25d1059b727) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69), deploy into slot with allocation id c664e6c8579a76e7d26e854dc9262b89.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 4bac63ee3ff94b2b5dd36930fa5966fe.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)#0 (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (9ecfe6cc5ae9fb5df8baf2a88399fd69) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f), deploy into slot with allocation id 4bac63ee3ff94b2b5dd36930fa5966fe.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [2]WriteToText/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)#0 39a4d9b16c66ce5ca50ae5d50f38f217.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16) (53e993114e7a84d7dc4da4bccbece64f) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0 (53e993114e7a84d7dc4da4bccbece64f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16) (53e993114e7a84d7dc4da4bccbece64f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot ded7ad69741b809eee2c0614e8baa30e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [2]WriteToText/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (39a4d9b16c66ce5ca50ae5d50f38f217) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job 817ad3a4134488a929dbf930e6e6f6b7: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=15}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (6e187d686a1f35e849e58a24e91751c8) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job 817ad3a4134488a929dbf930e6e6f6b7: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=16}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838), deploy into slot with allocation id ded7ad69741b809eee2c0614e8baa30e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (6e187d686a1f35e849e58a24e91751c8) switched from SCHEDULED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 892c7f70d71bdb94fc978913b1d6cb58.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution deploy'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Deploying CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (attempt #0) with attempt id 6e187d686a1f35e849e58a24e91751c8 to a42372b1-2ceb-4f9b-b831-1ba68f3f6052 @ localhost (dataPort=-1) with allocation id d0415eb8a947590a059d030c7f809d6e'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (f96293a2cbbd4a9f2abffc21f9220838) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (f96293a2cbbd4a9f2abffc21f9220838) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (f96293a2cbbd4a9f2abffc21f9220838) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-9'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c), deploy into slot with allocation id 892c7f70d71bdb94fc978913b1d6cb58.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot acb6d9d2f227d56877add69a97db859e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)#0 (a79c93ca990ccd2416d40c4966cf560c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (a79c93ca990ccd2416d40c4966cf560c) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff), deploy into slot with allocation id acb6d9d2f227d56877add69a97db859e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-10'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (6862273f8007ee2b8d4d2e4216c3e88d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (6862273f8007ee2b8d4d2e4216c3e88d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 6f26bb44b8fe7ffac105caca1265b061.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 (0ba9fd428139031e6fa790abb36841f7), deploy into slot with allocation id 6f26bb44b8fe7ffac105caca1265b061.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (a79c93ca990ccd2416d40c4966cf560c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-11'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 2-12'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (89d0d2730735876ed57f129f5585158d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (914fb46abc15d9a38e6205691db488ff) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 21, 2022 6:57:50 PM org.apache.flink.runtime.taskmanager.Task transitionState'
java.lang.OutOfMemoryError: GC overhead limit exceeded
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Python_Examples_Flink #55
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/55/display/redirect>
Changes:
------------------------------------------
[...truncated 62.28 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [7]{ReadFromBigQuery, Projected, DesiredMonth, ExtractMean, GlobalMean}) (7/16) (d0d7e8c4663052affbffa2bf60cccf95) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89), deploy into slot with allocation id 1130c3f8b2a2ab3c34ec38cd9df4f61c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [7]{ReadFromBigQuery, Projected, DesiredMonth, ExtractMean, GlobalMean}) (2/16) (1efafbf01d533f08c7334791e63ed064) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=7}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78), deploy into slot with allocation id 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (a0ee673f9693381e34eefbd0ddfe861d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 (a0ee673f9693381e34eefbd0ddfe861d).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [7]{ReadFromBigQuery, Projected, DesiredMonth, ExtractMean, GlobalMean}) (12/16) (b61faf9c92aa3fefcc86835ae755f173) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=6}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (11/16) (a2e546b3edbd3502a6f10a989ed888f8) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (11/16) (a2e546b3edbd3502a6f10a989ed888f8) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (11/16) (a0ee673f9693381e34eefbd0ddfe861d) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (11/16) (a0ee673f9693381e34eefbd0ddfe861d) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (10/16) (80746bd6e0989c2cb50d66bdc75f929d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01), deploy into slot with allocation id 4b06d62d355106c628cbe2630ff8e399.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (14/16) (c4acc64800eed03ee6957f3c7e017edf) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (14/16) (c4acc64800eed03ee6957f3c7e017edf) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (10/16)#0 89f8c569bd5352d89b6dfaacdf9cd678.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16) (8064a502df4cd5c37d9348614ff69b89) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (14/16)#0 (c4acc64800eed03ee6957f3c7e017edf) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16) (8064a502df4cd5c37d9348614ff69b89) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[3]) (14/16)#0 (c4acc64800eed03ee6957f3c7e017edf).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16) (a249944abb6b2bddbf7053af99650f78) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16) (a249944abb6b2bddbf7053af99650f78) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (10/16) (89f8c569bd5352d89b6dfaacdf9cd678) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=5}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (f83258934db3213323c5bd34d695ad01) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (f83258934db3213323c5bd34d695ad01) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2), deploy into slot with allocation id b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16) (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16) (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f), deploy into slot with allocation id b1b8c48207555702f0658c30e413cacc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[3]) (11/16)#0 a2e546b3edbd3502a6f10a989ed888f8.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) switched from CREATED to DEPLOYING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) [DEPLOYING].'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (11/16)#0 a0ee673f9693381e34eefbd0ddfe861d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 (8064a502df4cd5c37d9348614ff69b89).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (11/16) (a2e546b3edbd3502a6f10a989ed888f8) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[3]) (14/16)#0 c4acc64800eed03ee6957f3c7e017edf.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 (a249944abb6b2bddbf7053af99650f78).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (14/16)#0 8064a502df4cd5c37d9348614ff69b89.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (11/16) (a0ee673f9693381e34eefbd0ddfe861d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[3]) (7/16)#0 a249944abb6b2bddbf7053af99650f78.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=4}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (14/16) (c4acc64800eed03ee6957f3c7e017edf) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (14/16) (8064a502df4cd5c37d9348614ff69b89) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=3}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (7/16) (a249944abb6b2bddbf7053af99650f78) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (d7f0eba8386d231697e3edf04f84964f) switched from DEPLOYING to INITIALIZING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (d7f0eba8386d231697e3edf04f84964f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 (f83258934db3213323c5bd34d695ad01).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0 f83258934db3213323c5bd34d695ad01.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 (ca72f4f4b3f35a96c22ca5ede4ccb5f2).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (7/16) (f83258934db3213323c5bd34d695ad01) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[3]) (3/16)#0 ca72f4f4b3f35a96c22ca5ede4ccb5f2.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=2}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[3]) (3/16) (ca72f4f4b3f35a96c22ca5ede4ccb5f2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message."
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Freeing task resources for FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (d7f0eba8386d231697e3edf04f84964f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 d7f0eba8386d231697e3edf04f84964f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: FlatMap (FlatMap at ExtractOutput[0]) (3/16) (d7f0eba8386d231697e3edf04f84964f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:12:35 PM org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received resource requirements from job dfb816ad2f7aa07df8fe5afd0a091cc3: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]'
INFO apache_beam.io.gcp.bigquery_tools:bigquery_tools.py:557 Started BigQuery job: <JobReference
jobId: 'beam_bq_job_EXPORT_BQ_EXPORT_JOB_672d1732-0_1645294354_754'
location: 'US'
projectId: 'apache-beam-testing'>
bq show -j --format=prettyjson --project_id=apache-beam-testing beam_bq_job_EXPORT_BQ_EXPORT_JOB_672d1732-0_1645294354_754
INFO root:bigquery_tools.py:625 Job status: RUNNING
> Task :sdks:python:test-suites:portable:py39:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]read/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)#0 ca35161985ab823fb76f12d8aa9bff80.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:11:26 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: MapPartition (MapPartition at [4]{read, months with tornadoes, monthly count}) (15/16) (decfe243ef5641b07bfeaf65f50bbc57) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:11:26 PM org.apache.flink.runtime.taskexecutor.TaskExecutor unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [3]read/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0 d7494e55fc01eeca06eb243ef6696cfc.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:11:26 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (14/16) (208022837bfba45b1bbef5f13842a9e6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 6:11:26 PM org.apache.flink.runtime.executiongraph.Execution transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: DataSource (Impulse) (15/16) (1da735d50830467a091f500e3f418651) switched from RUNNING to FINISHED.'
java.lang.OutOfMemoryError: GC overhead limit exceeded
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org