See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/52/display/redirect?page=changes>
Changes: [rogelio.hernandez] [BEAM-13051] Pylint misplaced-bare-raise warning enabled [rogelio.hernandez] [BEAM-13051] Added descriptions to Kinesis and PortableRunner exceptions [thiagotnunes] fix: fix bug when retrieving either string or json [noreply] [BEAM-13812] Integrate DataprocClusterManager into Interactive [noreply] [BEAM-12572] Fix failing python examples tests in Dataflow runner ------------------------------------------ [...truncated 35.50 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 29755d5fdf79a6e6fcee5b23d531e39c.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16)#0 (25a3cdf4ff7bae56596724945457b0b2) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310), deploy into slot with allocation id 29755d5fdf79a6e6fcee5b23d531e39c.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16)#0 (25a3cdf4ff7bae56596724945457b0b2) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot be0714a7452dc2c901bced8927ec6997.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16)#0 (25a3cdf4ff7bae56596724945457b0b2) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16)#0 (25a3cdf4ff7bae56596724945457b0b2) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16) (25a3cdf4ff7bae56596724945457b0b2) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (6/16) (25a3cdf4ff7bae56596724945457b0b2) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16)#0 (ad382f6b00eafce1b34691ca1593a310) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16) (ad382f6b00eafce1b34691ca1593a310) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (7/16) (ad382f6b00eafce1b34691ca1593a310) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8), deploy into slot with allocation id be0714a7452dc2c901bced8927ec6997.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 76055b893ca3a378688b9caeab379cc1.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b), deploy into slot with allocation id 76055b893ca3a378688b9caeab379cc1.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 90c82c29243a73ef9418e6fa967454f9.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 3-63' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9), deploy into slot with allocation id 90c82c29243a73ef9418e6fa967454f9.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 3-64' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16)#0 (865a98faed09974ef21bc50b7c2fc35b) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16)#0 (bc75f08179efb3fda2dad60fb5e299a8) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16) (865a98faed09974ef21bc50b7c2fc35b) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16) (bc75f08179efb3fda2dad60fb5e299a8) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (9/16) (865a98faed09974ef21bc50b7c2fc35b) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (8/16) (bc75f08179efb3fda2dad60fb5e299a8) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot ac31ed4754194618a1453d17fcee0d34.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be), deploy into slot with allocation id ac31ed4754194618a1453d17fcee0d34.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot bbfe2d63c0f7cf84c959229b2dcb57d7.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16)#0 (55f9f6b3492f3f731838d001eeed65c9) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16) (55f9f6b3492f3f731838d001eeed65c9) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (10/16) (55f9f6b3492f3f731838d001eeed65c9) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16) (7777c0be01dae85805dc579fa0e4c5be) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16)#0 (7777c0be01dae85805dc579fa0e4c5be) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (11/16) (7777c0be01dae85805dc579fa0e4c5be) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb), deploy into slot with allocation id bbfe2d63c0f7cf84c959229b2dcb57d7.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 1173d1b53219134b1d8b787757e90972.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16)#0 (1a55c8cdeae550c7daabd5f8d237a2eb) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16) (1a55c8cdeae550c7daabd5f8d237a2eb) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (12/16) (1a55c8cdeae550c7daabd5f8d237a2eb) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: getProcessBundleDescriptor request with id 3-65' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8), deploy into slot with allocation id 1173d1b53219134b1d8b787757e90972.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot bbd5ce5d6beb6f451f6238e55cd41bde.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16)#0 (56295ed644767f45971224c99d513ad8) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16) (56295ed644767f45971224c99d513ad8) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (13/16) (56295ed644767f45971224c99d513ad8) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719), deploy into slot with allocation id bbd5ce5d6beb6f451f6238e55cd41bde.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot f7b6b4434bd33776092962b4075299c2.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16)#0 (26d0caf33f7d801baa71640450f00719) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16) (26d0caf33f7d801baa71640450f00719) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf), deploy into slot with allocation id f7b6b4434bd33776092962b4075299c2.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (14/16) (26d0caf33f7d801baa71640450f00719) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf) [DEPLOYING].' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot 7a719ba16cb6a04e23c424914dc7097d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16)#0 (f36c018a309d70b2e3ae448ae550aabf) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16) (f36c018a309d70b2e3ae448ae550aabf) switched from DEPLOYING to INITIALIZING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.executiongraph.Execution transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: GroupReduce (GroupReduce at WriteUserScoreSums/Write/WriteImpl/GroupByKey) (15/16) (f36c018a309d70b2e3ae448ae550aabf) switched from INITIALIZING to RUNNING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Received task CHAIN MapPartition (MapPartition at [1]WriteUserScoreSums/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (3a2e2dc248de2d0e0f02602a3c0f8f7c), deploy into slot with allocation id 7a719ba16cb6a04e23c424914dc7097d.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.beam.sdk.io.aws2.s3.DefaultS3ClientBuilderFactory createBuilder' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO: The AWS S3 Beam extension was included in this build, but the awsRegion flag was not specified. If you don't plan to use S3, then ignore this message." INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task transitionState' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: CHAIN MapPartition (MapPartition at [1]WriteUserScoreSums/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (3a2e2dc248de2d0e0f02602a3c0f8f7c) switched from CREATED to DEPLOYING.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Activate slot d7b8644e35a70ed20e5103f66770d4ce.' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 19, 2022 12:08:51 AM org.apache.flink.runtime.taskmanager.Task doRun' INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [1]WriteUserScoreSums/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (3a2e2dc248de2d0e0f02602a3c0f8f7c) [DEPLOYING].' Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
