Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #71

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/71/display/redirect>

------------------------------------------
[...truncated 80.84 MB...]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16).
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (15/16) (442ccfc5f006b279b671d118b57be466) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 2388b6738707d0c8bdd3b01f84193c12.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (15/16) (442ccfc5f006b279b671d118b57be466) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (15/16) (442ccfc5f006b279b671d118b57be466) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (15/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (56b096450e34f33cc4232e5f87c35ca6) switched from CREATED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 4323d01cb47a67fd8de928a2aa2ec289.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (56b096450e34f33cc4232e5f87c35ca6) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (56b096450e34f33cc4232e5f87c35ca6) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (10/16) (2388b6738707d0c8bdd3b01f84193c12) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (56b096450e34f33cc4232e5f87c35ca6) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (11/16) (4323d01cb47a67fd8de928a2aa2ec289) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (56b096450e34f33cc4232e5f87c35ca6) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (15/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16).
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (56b096450e34f33cc4232e5f87c35ca6) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (df692ba2d34a69a21d368299b14ea375) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (df692ba2d34a69a21d368299b14ea375) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (df692ba2d34a69a21d368299b14ea375) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (df692ba2d34a69a21d368299b14ea375) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16).
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (df692ba2d34a69a21d368299b14ea375) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (df692ba2d34a69a21d368299b14ea375) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 08f3452ceeb06ee47e105afb3b3f8a7a.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (fe85de8ca5a822bc885e693aca7e08b4) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (fe85de8ca5a822bc885e693aca7e08b4) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (fe85de8ca5a822bc885e693aca7e08b4) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (3/16) (08f3452ceeb06ee47e105afb3b3f8a7a) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (fe85de8ca5a822bc885e693aca7e08b4) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (fe85de8ca5a822bc885e693aca7e08b4) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (fe85de8ca5a822bc885e693aca7e08b4) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 665ce9d5ac5cbbb1722db2ad113e983d.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (906d74272f218d2f014052f7ea6617dd) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (906d74272f218d2f014052f7ea6617dd) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (906d74272f218d2f014052f7ea6617dd) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (7/16) (665ce9d5ac5cbbb1722db2ad113e983d) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (906d74272f218d2f014052f7ea6617dd) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (906d74272f218d2f014052f7ea6617dd) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (906d74272f218d2f014052f7ea6617dd) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 9c4d40402c293f9b47aa6f822a37533f.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (7c589d3b4b4a972788e12b2805ca6274) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (7c589d3b4b4a972788e12b2805ca6274) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (7c589d3b4b4a972788e12b2805ca6274) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (5/16) (9c4d40402c293f9b47aa6f822a37533f) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (7c589d3b4b4a972788e12b2805ca6274) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16).
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (7c589d3b4b4a972788e12b2805ca6274) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (7c589d3b4b4a972788e12b2805ca6274) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 29b421c878a572db239905b9bb104555.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (3fe3039bbe67c138af1213c9b568c828) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (3fe3039bbe67c138af1213c9b568c828) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (3fe3039bbe67c138af1213c9b568c828) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (1/16) (29b421c878a572db239905b9bb104555) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16).
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (3fe3039bbe67c138af1213c9b568c828) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (3fe3039bbe67c138af1213c9b568c828) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (3fe3039bbe67c138af1213c9b568c828) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) a54e4a056368877194d41e1104d2b3eb.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16) (de515e089310f25dfe922f54a3c8d6fa) switched from CREATED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) fea47802ffaec81643ff25195e9faa4e.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16) (de515e089310f25dfe922f54a3c8d6fa) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 4cf7a60fa2bfc98c3d17e7953a8d2a33.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16) (de515e089310f25dfe922f54a3c8d6fa) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 038b4392195a97a6e340170fdaecc8b1.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (6/16) (a54e4a056368877194d41e1104d2b3eb) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (9/16) (fea47802ffaec81643ff25195e9faa4e) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16) (de515e089310f25dfe922f54a3c8d6fa) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (8/16) (4cf7a60fa2bfc98c3d17e7953a8d2a33) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16) (de515e089310f25dfe922f54a3c8d6fa) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (16/16) (038b4392195a97a6e340170fdaecc8b1) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16) (de515e089310f25dfe922f54a3c8d6fa) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16).
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (8cbeb1199838a5edd78c63adfb2c399a) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (8cbeb1199838a5edd78c63adfb2c399a) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (8cbeb1199838a5edd78c63adfb2c399a) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (8cbeb1199838a5edd78c63adfb2c399a) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16).
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (8cbeb1199838a5edd78c63adfb2c399a) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (8cbeb1199838a5edd78c63adfb2c399a) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f2d36cf931822101172487400b2dcbdc) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f2d36cf931822101172487400b2dcbdc) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f2d36cf931822101172487400b2dcbdc) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16).
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f2d36cf931822101172487400b2dcbdc) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f2d36cf931822101172487400b2dcbdc) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f2d36cf931822101172487400b2dcbdc) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (902c054f8f80cf09a09dd1d54ba830a1) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (902c054f8f80cf09a09dd1d54ba830a1) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (902c054f8f80cf09a09dd1d54ba830a1) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16).
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (902c054f8f80cf09a09dd1d54ba830a1) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (902c054f8f80cf09a09dd1d54ba830a1) switched from DEPLOYING to RUNNING.
    [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 (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) bf4aa769f5022096503da46a96afee7b.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (902c054f8f80cf09a09dd1d54ba830a1) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (c909d78189a011df87850f657d6259f2) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (c909d78189a011df87850f657d6259f2) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (c909d78189a011df87850f657d6259f2) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (2/16) (bf4aa769f5022096503da46a96afee7b) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (c909d78189a011df87850f657d6259f2) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (c909d78189a011df87850f657d6259f2) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (c909d78189a011df87850f657d6259f2) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16).
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0c84cb72050d950c4dcdad199a2b7ba5) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0c84cb72050d950c4dcdad199a2b7ba5) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0c84cb72050d950c4dcdad199a2b7ba5) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0c84cb72050d950c4dcdad199a2b7ba5) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0c84cb72050d950c4dcdad199a2b7ba5) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0c84cb72050d950c4dcdad199a2b7ba5) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (15/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] WARN org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to pull docker image jenkins-docker-apache.bintray.io/beam/java, cause: Received exit code 1 for command 'docker pull jenkins-docker-apache.bintray.io/beam/java'. stderr: Error response from daemon: unknown: Repo 'apache' was not found

org.apache.beam.sdk.transforms.ParDoTest$TimerTests > testAbsoluteProcessingTimeTimerRejected STANDARD_ERROR
    [Test worker] INFO org.apache.beam.runners.core.construction.ArtifactServiceStager - Staged 186 files (token: {"sessionId":"pardotest0timertests0testabsoluteprocessingtimetimerrejected-jenkins-1202061444-87e79994_e11ddd07-84fc-478f-8e8c-ab5371324401","basePath":"/tmp/beam-artifact-staging"})
    [grpc-default-executor-41] INFO org.apache.beam.runners.flink.FlinkJobInvoker - Invoking job pardotest0timertests0testabsoluteprocessingtimetimerrejected-jenkins-1202061444-87e79994_a3db278d-c659-4558-9910-3aa5aa40b7d4
    [grpc-default-executor-41] INFO org.apache.beam.runners.flink.FlinkJobInvocation - Starting job invocation pardotest0timertests0testabsoluteprocessingtimetimerrejected-jenkins-1202061444-87e79994_a3db278d-c659-4558-9910-3aa5aa40b7d4
    [Test worker] INFO org.apache.beam.runners.reference.PortableRunner - RunJobResponse: job_id: "pardotest0timertests0testabsoluteprocessingtimetimerrejected-jenkins-1202061444-87e79994_a3db278d-c659-4558-9910-3aa5aa40b7d4"

    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkJobInvocation - Translating pipeline to Flink program.
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkExecutionEnvironments - Creating a Batch Execution Environment.
    [flink-runner-job-server] INFO org.apache.flink.api.java.ExecutionEnvironment - The job has 0 registered types and 0 default Kryo serializers
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Flink Mini Cluster
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Metrics Registry
    [flink-runner-job-server] INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter configured, no metrics will be exposed/reported.
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting RPC Service(s)
    [flink-akka.actor.default-dispatcher-4] INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting high-availability services
    [flink-runner-job-server] INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /tmp/blobStore-e9e79739-57f9-4772-b61c-786ee51e835f
    [flink-runner-job-server] INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:44985 - max concurrent requests: 50 - max backlog: 1000
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting ResourceManger
    [flink-runner-job-server] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/resourcemanager_35e32b3f-0a4f-4bb2-ab77-fdbddba1d4bb .
    [flink-runner-job-server] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.resourcemanager.StandaloneResourceManager@603d42e8 @ akka://flink/user/resourcemanager_35e32b3f-0a4f-4bb2-ab77-fdbddba1d4bb
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - ResourceManager akka://flink/user/resourcemanager_35e32b3f-0a4f-4bb2-ab77-fdbddba1d4bb was granted leadership with fencing token ac5990a9438d8af91717ca96fa35439b
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Starting the SlotManager.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/resourcemanager_35e32b3f-0a4f-4bb2-ab77-fdbddba1d4bb , session=1717ca96-fa35-439b-ac59-90a9438d8af9
    [flink-runner-job-server] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Created BLOB cache storage directory /tmp/blobStore-c5ef9d60-045e-40d2-9ba6-89f047cd057b
    [flink-runner-job-server] INFO org.apache.flink.runtime.blob.TransientBlobCache - Created BLOB cache storage directory /tmp/blobStore-ee0f6ce0-eafe-417a-be7f-509e75bab72a
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting 1 TaskManger(s)
    [flink-runner-job-server] INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Starting TaskManager with ResourceID: 7e2e5584-e4e6-4d89-8001-d1d46ef22d28
    [flink-runner-job-server] INFO org.apache.flink.runtime.taskexecutor.TaskManagerServices - Temporary file directory '/tmp': total 484 GB, usable 306 GB (63.22% usable)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007fde13afb000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 12288 bytes for committing reserved memory.
# An error report file with more information is saved as:
# <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/ws/src/runners/flink/job-server/hs_err_pid14328.log>
Could not stop org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@17bfe00a.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message [MethodInvocation method: stop()].
	at org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:34)
	at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:31)
	at org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:133)
	at org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:34)
	at org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:73)
	at org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
	at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
	at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
	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:55)
	at java.lang.Thread.run(Thread.java:748)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test Executor 2' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
	at org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:155)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:29)
	... 10 more

org.apache.beam.sdk.transforms.ParDoTest$TimerTests > testAbsoluteProcessingTimeTimerRejected SKIPPED

org.apache.beam.sdk.transforms.ParDoTest$StateTests > testCoderInferenceOfList SKIPPED

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 3,5,main]) completed. Took 12 mins 0.957 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 137
  This problem might be caused by incorrect test process configuration.
  Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 16m 10s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/tuxw5txvugo54

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