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 2020/09/15 12:11:18 UTC
Build failed in Jenkins: beam_PreCommit_Portable_Python_Cron #2599
See <https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/2599/display/redirect>
Changes:
------------------------------------------
[...truncated 681.43 KB...]
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (5950c99e68cbdf291584bfc0811d69e4) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) exceeded the 80 characters length limit and was truncated.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2).
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf) switched from CREATED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf) [DEPLOYING]
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) exceeded the 80 characters length limit and was truncated.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2).
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (a4f4bf43293eb0562540a82011a64872) switched from CREATED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (Impulse) (1/2) a8304e11e91475bf3a8737460f1ddf97.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (a4f4bf43293eb0562540a82011a64872) [DEPLOYING]
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (a4f4bf43293eb0562540a82011a64872) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (Impulse) (1/2) 468abb27a9b46650c8afc72da40c8f32.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (1/2) (a8304e11e91475bf3a8737460f1ddf97) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (1/2) (468abb27a9b46650c8afc72da40c8f32) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (a4f4bf43293eb0562540a82011a64872) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (a4f4bf43293eb0562540a82011a64872) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (a4f4bf43293eb0562540a82011a64872) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [2]Read/Read/_SDFBoundedSourceWrapper/ParDo(SDFBoundedSourceDoFn)/{PairWithRestriction0, SplitAndSize0}) exceeded the 80 characters length limit and was truncated.
INFO:apache_beam.runners.worker.statecache:Creating state cache with size 0
INFO:apache_beam.runners.worker.sdk_worker:Creating insecure control channel for localhost:33575.
INFO:apache_beam.runners.worker.sdk_worker:Control channel established.
INFO:apache_beam.runners.worker.sdk_worker:Initializing SDKHarness with unbounded number of workers.
INFO:apache_beam.utils.subprocess_server:[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - Beam Fn Control client connected with id 1-1
INFO:apache_beam.utils.subprocess_server:[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 1-3
INFO:apache_beam.utils.subprocess_server:[grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 1-2
INFO:apache_beam.runners.worker.sdk_worker:Creating insecure state channel for localhost:46629.
INFO:apache_beam.runners.worker.sdk_worker:State channel established.
INFO:apache_beam.utils.subprocess_server:[grpc-default-executor-1] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 1-4
INFO:apache_beam.runners.worker.data_plane:Creating client data channel for localhost:33099
INFO:apache_beam.utils.subprocess_server:[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 1-5
INFO:apache_beam.utils.subprocess_server:[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.data.GrpcDataService - Beam Fn Data client connected.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (5950c99e68cbdf291584bfc0811d69e4) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (5950c99e68cbdf291584bfc0811d69e4).
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (5950c99e68cbdf291584bfc0811d69e4) [FINISHED]
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) 5950c99e68cbdf291584bfc0811d69e4.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (5950c99e68cbdf291584bfc0811d69e4) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf).
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf) [FINISHED]
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) 280ffd8f051771f7ed66290347dfbdcf.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [2]Write/Write/WriteImpl/DoOnce/{FlatMap(<lambda at core.py:2876>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (280ffd8f051771f7ed66290347dfbdcf) switched from RUNNING to FINISHED.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (416c0abd018860870ee089e4fb7bd2e0) switched from CREATED to SCHEDULED.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (d540c975700af1a4f2729bfd0ffe8b85) switched from CREATED to SCHEDULED.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (7d45cf20e04b5ef1ea2e1ea205771537) switched from CREATED to SCHEDULED.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (01bed8cf10786dfabe150c2b2e702c56) switched from CREATED to SCHEDULED.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2) (68f59b78272bb58ff1647f0ddfe45b3c) switched from CREATED to SCHEDULED.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2) (758ba03d95fa1b9d21951b250b8d1e99) switched from CREATED to SCHEDULED.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (416c0abd018860870ee089e4fb7bd2e0) switched from SCHEDULED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (attempt #0) to eca828c9-b602-48cf-a2e0-4ec8e007fdc1 @ localhost (dataPort=-1)
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (d540c975700af1a4f2729bfd0ffe8b85) switched from SCHEDULED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (attempt #0) to eca828c9-b602-48cf-a2e0-4ec8e007fdc1 @ localhost (dataPort=-1)
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2).
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (7d45cf20e04b5ef1ea2e1ea205771537) switched from SCHEDULED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (attempt #0) to eca828c9-b602-48cf-a2e0-4ec8e007fdc1 @ localhost (dataPort=-1)
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (416c0abd018860870ee089e4fb7bd2e0) switched from CREATED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (416c0abd018860870ee089e4fb7bd2e0) [DEPLOYING]
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (416c0abd018860870ee089e4fb7bd2e0) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (416c0abd018860870ee089e4fb7bd2e0) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (01bed8cf10786dfabe150c2b2e702c56) switched from SCHEDULED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (attempt #0) to eca828c9-b602-48cf-a2e0-4ec8e007fdc1 @ localhost (dataPort=-1)
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2) (68f59b78272bb58ff1647f0ddfe45b3c) switched from SCHEDULED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2).
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2) (attempt #0) to eca828c9-b602-48cf-a2e0-4ec8e007fdc1 @ localhost (dataPort=-1)
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (d540c975700af1a4f2729bfd0ffe8b85) switched from CREATED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (416c0abd018860870ee089e4fb7bd2e0) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (d540c975700af1a4f2729bfd0ffe8b85) [DEPLOYING]
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (d540c975700af1a4f2729bfd0ffe8b85) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2) (758ba03d95fa1b9d21951b250b8d1e99) switched from SCHEDULED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2) (attempt #0) to eca828c9-b602-48cf-a2e0-4ec8e007fdc1 @ localhost (dataPort=-1)
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (d540c975700af1a4f2729bfd0ffe8b85) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (416c0abd018860870ee089e4fb7bd2e0) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (d540c975700af1a4f2729bfd0ffe8b85) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/InitializeWrite) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (d540c975700af1a4f2729bfd0ffe8b85) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2).
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (7d45cf20e04b5ef1ea2e1ea205771537) switched from CREATED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (7d45cf20e04b5ef1ea2e1ea205771537) [DEPLOYING]
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (7d45cf20e04b5ef1ea2e1ea205771537) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (7d45cf20e04b5ef1ea2e1ea205771537) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2).
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (7d45cf20e04b5ef1ea2e1ea205771537) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (1/2) (7d45cf20e04b5ef1ea2e1ea205771537) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (01bed8cf10786dfabe150c2b2e702c56) switched from CREATED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (01bed8cf10786dfabe150c2b2e702c56) [DEPLOYING]
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (01bed8cf10786dfabe150c2b2e702c56) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (01bed8cf10786dfabe150c2b2e702c56) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (01bed8cf10786dfabe150c2b2e702c56) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2).
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [1]Write/Write/WriteImpl/PreFinalize) -> FlatMap (FlatMap at ExtractOutput[0]) (2/2) (01bed8cf10786dfabe150c2b2e702c56) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2) (68f59b78272bb58ff1647f0ddfe45b3c) switched from CREATED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2) (68f59b78272bb58ff1647f0ddfe45b3c) [DEPLOYING]
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2) (68f59b78272bb58ff1647f0ddfe45b3c) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2) (68f59b78272bb58ff1647f0ddfe45b3c) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2).
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2) (758ba03d95fa1b9d21951b250b8d1e99) switched from CREATED to DEPLOYING.
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2) (758ba03d95fa1b9d21951b250b8d1e99) [DEPLOYING]
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2) (758ba03d95fa1b9d21951b250b8d1e99) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2) (758ba03d95fa1b9d21951b250b8d1e99) [DEPLOYING].
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2) (68f59b78272bb58ff1647f0ddfe45b3c) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2) (758ba03d95fa1b9d21951b250b8d1e99) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (1/2) (68f59b78272bb58ff1647f0ddfe45b3c) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [1]Write/Write/WriteImpl/FinalizeWrite) (2/2) (758ba03d95fa1b9d21951b250b8d1e99) switched from DEPLOYING to RUNNING.
INFO:apache_beam.utils.subprocess_server:[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 1-6
INFO:apache_beam.utils.subprocess_server:[grpc-default-executor-0] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - getProcessBundleDescriptor request with id 1-7
INFO:apache_beam.utils.subprocess_server:[PermanentBlobCache shutdown hook] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
INFO:apache_beam.utils.subprocess_server:[TaskExecutorLocalStateStoresManager shutdown hook] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
INFO:apache_beam.utils.subprocess_server:[TransientBlobCache shutdown hook] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
INFO:apache_beam.utils.subprocess_server:[BlobServer shutdown hook] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:39523
INFO:apache_beam.utils.subprocess_server:[FileCache shutdown hook] INFO org.apache.flink.runtime.filecache.FileCache - removed file cache directory /tmp/flink-dist-cache-d6cf4544-119d-4bdf-bae0-d06b78848c31
INFO:apache_beam.utils.subprocess_server:[FileChannelManagerImpl-io shutdown hook] INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager removed spill file directory /tmp/flink-io-e13038a2-ff61-4f9b-b3d9-fbbbaa227f76
INFO:apache_beam.utils.subprocess_server:[FileChannelManagerImpl-netty-shuffle shutdown hook] INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager removed spill file directory /tmp/flink-netty-shuffle-1d37339e-d99e-462f-aa0f-8cb449b36633
Exception in thread read_state:
Traceback (most recent call last):
File "/usr/lib/python2.7/threading.py", line 801, in __bootstrap_inner
self.run()
File "/usr/lib/python2.7/threading.py", line 754, in run
self.__target(*self.__args, **self.__kwargs)
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",> line 819, in pull_responses
for response in responses:
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",> line 413, in next
return self._next()
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",> line 706, in _next
raise self
_MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string = "{"created":"@1600171864.277664231","description":"Error received from peer ipv4:127.0.0.1:46629","file":"src/core/lib/surface/call.cc","file_line":1062,"grpc_message":"Socket closed","grpc_status":14}"
>
ERROR:apache_beam.runners.worker.data_plane:Failed to read inputs in the data plane.
Traceback (most recent call last):
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/apache_beam/runners/worker/data_plane.py",> line 524, in _read_inputs
for elements in elements_iterator:
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",> line 413, in next
return self._next()
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",> line 706, in _next
raise self
_MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "Connection reset by peer"
debug_error_string = "{"created":"@1600171864.277614475","description":"Error received from peer ipv4:127.0.0.1:33099","file":"src/core/lib/surface/call.cc","file_line":1062,"grpc_message":"Connection reset by peer","grpc_status":14}"
>
Exception in thread read_grpc_client_inputs:
Traceback (most recent call last):
File "/usr/lib/python2.7/threading.py", line 801, in __bootstrap_inner
self.run()
File "/usr/lib/python2.7/threading.py", line 754, in run
self.__target(*self.__args, **self.__kwargs)
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/apache_beam/runners/worker/data_plane.py",> line 541, in <lambda>
target=lambda: self._read_inputs(elements_iterator),
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/apache_beam/runners/worker/data_plane.py",> line 524, in _read_inputs
for elements in elements_iterator:
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",> line 413, in next
return self._next()
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",> line 706, in _next
raise self
_MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "Connection reset by peer"
debug_error_string = "{"created":"@1600171864.277614475","description":"Error received from peer ipv4:127.0.0.1:33099","file":"src/core/lib/surface/call.cc","file_line":1062,"grpc_message":"Connection reset by peer","grpc_status":14}"
>
Exception in thread run_worker_1-1:
Traceback (most recent call last):
File "/usr/lib/python2.7/threading.py", line 801, in __bootstrap_inner
self.run()
File "/usr/lib/python2.7/threading.py", line 754, in run
self.__target(*self.__args, **self.__kwargs)
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker.py",> line 226, in run
for work_request in self._control_stub.Control(get_responses()):
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",> line 413, in next
return self._next()
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/grpc/_channel.py",> line 706, in _next
raise self
_MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "Connection reset by peer"
debug_error_string = "{"created":"@1600171864.277673869","description":"Error received from peer ipv4:127.0.0.1:33575","file":"src/core/lib/surface/call.cc","file_line":1062,"grpc_message":"Connection reset by peer","grpc_status":14}"
>
Traceback (most recent call last):
File "/usr/lib/python2.7/runpy.py", line 174, in _run_module_as_main
"__main__", fname, loader, pkg_name)
File "/usr/lib/python2.7/runpy.py", line 72, in _run_code
exec code in run_globals
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/lib/python2.7/site-packages/apache_beam/examples/wordcount.py",> line 99, in <module>
run()
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/lib/python2.7/site-packages/apache_beam/examples/wordcount.py",> line 94, in run
output | 'Write' >> WriteToText(known_args.output)
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/apache_beam/pipeline.py",> line 569, in __exit__
self.result.wait_until_finish()
File "<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/apache_beam/runners/portability/portable_runner.py",> line 551, in wait_until_finish
raise self._runtime_exception
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string = "{"created":"@1600171864.278024717","description":"Error received from peer ipv4:127.0.0.1:40921","file":"src/core/lib/surface/call.cc","file_line":1062,"grpc_message":"Socket closed","grpc_status":14}"
>
> Task :sdks:python:test-suites:portable:py2:portableWordCountFlinkRunnerBatch FAILED
> Task :sdks:python:test-suites:portable:py2:portableWordCountFlinkRunnerStreaming
<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src/build/gradleenv/1866363813/local/lib/python2.7/site-packages/apache_beam/__init__.py>:82: UserWarning: You are using the final Apache Beam release with Python 2 support. New releases of Apache Beam will require Python 3.6 or a newer version.
'You are using the final Apache Beam release with Python 2 support. '
Daemon will be stopped at the end of the build after the daemon was no longer found in the daemon registry
The message received from the daemon indicates that the daemon has disappeared.
Build request sent: Build{id=2f3087b5-6a6a-42d6-ac70-8346f6949d78, currentDir=<https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/ws/src}>
Attempting to read last messages from the daemon log...
Daemon pid: 16624
log file: /home/jenkins/.gradle/daemon/6.6.1/daemon-16624.out.log
----- Last 20 lines from daemon log file - daemon-16624.out.log -----
at org.gradle.process.internal.DefaultExecHandle.execExceptionFor(DefaultExecHandle.java:241)
at org.gradle.process.internal.DefaultExecHandle.setEndStateInfo(DefaultExecHandle.java:218)
at org.gradle.process.internal.DefaultExecHandle.failed(DefaultExecHandle.java:369)
at org.gradle.process.internal.ExecHandleRunner.run(ExecHandleRunner.java:87)
at org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64)
at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:48)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IllegalStateException: Shutdown in progress
at java.lang.ApplicationShutdownHooks.remove(ApplicationShutdownHooks.java:82)
at java.lang.Runtime.removeShutdownHook(Runtime.java:239)
at org.gradle.process.internal.shutdown.ShutdownHooks.removeShutdownHook(ShutdownHooks.java:33)
at org.gradle.process.internal.DefaultExecHandle.setEndStateInfo(DefaultExecHandle.java:208)
at org.gradle.process.internal.DefaultExecHandle.aborted(DefaultExecHandle.java:365)
at org.gradle.process.internal.ExecHandleRunner.completed(ExecHandleRunner.java:108)
at org.gradle.process.internal.ExecHandleRunner.run(ExecHandleRunner.java:84)
... 7 more
----- End of the daemon log -----
FAILURE: Build failed with an exception.
* What went wrong:
Gradle build daemon disappeared unexpectedly (it may have been killed or may have crashed)
* 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_PreCommit_Portable_Python_Cron #2600
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://ci-beam.apache.org/job/beam_PreCommit_Portable_Python_Cron/2600/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org