Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #231

[Apache Jenkins Server]

See 
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/231/display/redirect?page=changes>

Changes:

[robertwb] Remove unused is_pair_like hack.

------------------------------------------
[...truncated 81.68 MB...]
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) switched 
from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Creating FileSystem stream leak safety net for task CHAIN MapPartition 
(MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Loading JAR files for task CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Registering task at network: CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) switched 
from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16) (937676c23a32644d018df3f6e392bb1f) switched 
from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (13/16)] WARN org.apache.flink.metrics.MetricGroup - 
The operator name MapPartition (MapPartition at 
PAssert$24/GroupGlobally/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 - Received task CHAIN 
MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16).
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (16/16) (f6fbc704fd3658e78c80635dd9ec9323) switched 
from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (16/16) (f6fbc704fd3658e78c80635dd9ec9323) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (16/16) (f6fbc704fd3658e78c80635dd9ec9323) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (16/16) (f6fbc704fd3658e78c80635dd9ec9323) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (16/16) (f6fbc704fd3658e78c80635dd9ec9323) switched 
from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (16/16) (f6fbc704fd3658e78c80635dd9ec9323) switched 
from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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: 
PAssert$25/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (1/16).
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (d9d2fe080bb170cfb7b675ebdac39565) switched 
from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Creating FileSystem stream leak safety net for task CHAIN MapPartition 
(MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (d9d2fe080bb170cfb7b675ebdac39565) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Loading JAR files for task CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (d9d2fe080bb170cfb7b675ebdac39565) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Registering task at network: CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (d9d2fe080bb170cfb7b675ebdac39565) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (d9d2fe080bb170cfb7b675ebdac39565) switched 
from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN 
MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16).
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (d9d2fe080bb170cfb7b675ebdac39565) switched 
from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - 
The operator name MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - 
The operator name GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (1/16) (a9fe647461790b361951d56ee07a46a1) switched from 
CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (3/16) (ac4baffa38da5f2f0b75835919e3133f) switched from 
CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (3/16) (ac4baffa38da5f2f0b75835919e3133f) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (3/16) (ac4baffa38da5f2f0b75835919e3133f) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (1/16) (a9fe647461790b361951d56ee07a46a1) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (1/16) (a9fe647461790b361951d56ee07a46a1) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (3/16) (ac4baffa38da5f2f0b75835919e3133f) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (1/16) (a9fe647461790b361951d56ee07a46a1) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - 
The operator name FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (10/16).
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (0e5e2c296635a44bf41c06a46a8f015a) switched 
from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Creating FileSystem stream leak safety net for task CHAIN MapPartition 
(MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (0e5e2c296635a44bf41c06a46a8f015a) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Loading JAR files for task CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (0e5e2c296635a44bf41c06a46a8f015a) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Registering task at network: CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (0e5e2c296635a44bf41c06a46a8f015a) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (0e5e2c296635a44bf41c06a46a8f015a) switched 
from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16) (0e5e2c296635a44bf41c06a46a8f015a) switched 
from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - 
The operator name MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - 
The operator name GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (3/16) (ac4baffa38da5f2f0b75835919e3133f) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/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 
PAssert$25/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$25/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (3/16) (ac4baffa38da5f2f0b75835919e3133f) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (1/16) (a9fe647461790b361951d56ee07a46a1) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (1/16) (a9fe647461790b361951d56ee07a46a1) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (2/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16).
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (10/16) (d4d30e8f61ef4e435e916304d9659b7f) switched 
from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (10/16) (d4d30e8f61ef4e435e916304d9659b7f) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (10/16) (d4d30e8f61ef4e435e916304d9659b7f) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (10/16) (d4d30e8f61ef4e435e916304d9659b7f) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16).
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (4b541da3f35a7a9ad85a81b716b7868b) switched from 
CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (4b541da3f35a7a9ad85a81b716b7868b) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (4b541da3f35a7a9ad85a81b716b7868b) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (4b541da3f35a7a9ad85a81b716b7868b) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (4b541da3f35a7a9ad85a81b716b7868b) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/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-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (4b541da3f35a7a9ad85a81b716b7868b) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (10/16) (d4d30e8f61ef4e435e916304d9659b7f) switched 
from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (10/16) (d4d30e8f61ef4e435e916304d9659b7f) switched 
from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (6813df827745eda8d751925637c715c1) switched from 
CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Creating FileSystem stream leak safety net for task CHAIN MapPartition 
(MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (6813df827745eda8d751925637c715c1) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Loading JAR files for task CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (6813df827745eda8d751925637c715c1) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Registering task at network: CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (6813df827745eda8d751925637c715c1) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN 
MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16).
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (6813df827745eda8d751925637c715c1) switched from 
DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (6813df827745eda8d751925637c715c1) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16).
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (9a22e10eecc4261e352d0f1836ca4f9a) switched from 
CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Creating FileSystem stream leak safety net for task CHAIN MapPartition 
(MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (9a22e10eecc4261e352d0f1836ca4f9a) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Loading JAR files for task CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (9a22e10eecc4261e352d0f1836ca4f9a) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- Registering task at network: CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (9a22e10eecc4261e352d0f1836ca4f9a) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (9a22e10eecc4261e352d0f1836ca4f9a) switched from 
DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16) (9a22e10eecc4261e352d0f1836ca4f9a) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
PAssert$24/GroupGlobally/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (a9c7ba421cd301e9898f6f2ce9c29610) switched from 
CREATED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-3] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN 
MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16).
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (a9c7ba421cd301e9898f6f2ce9c29610) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (a9c7ba421cd301e9898f6f2ce9c29610) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (a9c7ba421cd301e9898f6f2ce9c29610) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
PAssert$24/GroupGlobally/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 
PAssert$24/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (2/16).
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16) (db517ebcf778c12dd8a7060e94200549) switched 
from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16) (db517ebcf778c12dd8a7060e94200549) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16) (db517ebcf778c12dd8a7060e94200549) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16) (db517ebcf778c12dd8a7060e94200549) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16) (db517ebcf778c12dd8a7060e94200549) switched 
from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16) (db517ebcf778c12dd8a7060e94200549) switched 
from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - 
The operator name MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - 
The operator name GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (a9c7ba421cd301e9898f6f2ce9c29610) switched from 
DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (a9c7ba421cd301e9898f6f2ce9c29610) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - 
The operator name FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16).
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (2/16) (1eccf7a129df4bccc9e7f6223d299cb6) switched from 
CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (2/16) (1eccf7a129df4bccc9e7f6223d299cb6) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (2/16) (1eccf7a129df4bccc9e7f6223d299cb6) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (2/16) (1eccf7a129df4bccc9e7f6223d299cb6) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (2/16) (1eccf7a129df4bccc9e7f6223d299cb6) switched from 
DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (2/16) (1eccf7a129df4bccc9e7f6223d299cb6) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16).
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16) (231415eea0a0a047a528ccf7cbcbf47b) switched from 
CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16) (231415eea0a0a047a528ccf7cbcbf47b) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16) (231415eea0a0a047a528ccf7cbcbf47b) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16) (231415eea0a0a047a528ccf7cbcbf47b) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16) (231415eea0a0a047a528ccf7cbcbf47b) switched from 
DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16) (231415eea0a0a047a528ccf7cbcbf47b) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16).
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (7af1080522953e00317e4d0d18c60aac) switched from 
CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (7af1080522953e00317e4d0d18c60aac) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (7af1080522953e00317e4d0d18c60aac) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (bd3f2ecdb2f9be016df5805f6268d3d1) switched from 
CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (7af1080522953e00317e4d0d18c60aac) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (7af1080522953e00317e4d0d18c60aac) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (bd3f2ecdb2f9be016df5805f6268d3d1) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (bd3f2ecdb2f9be016df5805f6268d3d1) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (bd3f2ecdb2f9be016df5805f6268d3d1) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task 
- CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (bd3f2ecdb2f9be016df5805f6268d3d1) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 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 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16) (bd3f2ecdb2f9be016df5805f6268d3d1) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/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-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition 
(MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (5/16) (7af1080522953e00317e4d0d18c60aac) switched from 
DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Combine.globally(Composed)/CreateVoid/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey)
 -> Map (Key Extractor) (6/16)] WARN org.apache.flink.metrics.MetricGroup - The 
operator name FlatMap (FlatMap at 
Combine.globally(Composed)/CreateVoid/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0)
 -> FlatMap (FlatMap at 
Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: 
Create.TimestampedValues/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.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0)
 exceeded the 80 characters length limit and was truncated.

org.apache.beam.sdk.transforms.ViewTest > 
testMapSideInputWithNonDeterministicKeyCoder STANDARD_ERROR
    [grpc-default-executor-87] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - GetManifest for 
/tmp/beam-artifact-staging/viewtest0testmapsideinputwithnondeterministickeycoder-jenkins-1106125608-1bad7c97_9dedbfef-b07a-4a8d-893b-172f1a5331e2/MANIFEST
    [grpc-default-executor-87] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - Loading manifest for retrieval token 
/tmp/beam-artifact-staging/viewtest0testmapsideinputwithnondeterministickeycoder-jenkins-1106125608-1bad7c97_9dedbfef-b07a-4a8d-893b-172f1a5331e2/MANIFEST
    [grpc-default-executor-87] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - Manifest at 
/tmp/beam-artifact-staging/viewtest0testmapsideinputwithnondeterministickeycoder-jenkins-1106125608-1bad7c97_9dedbfef-b07a-4a8d-893b-172f1a5331e2/MANIFEST
 has 185 artifact locations
    [grpc-default-executor-87] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - GetManifest for 
/tmp/beam-artifact-staging/viewtest0testmapsideinputwithnondeterministickeycoder-jenkins-1106125608-1bad7c97_9dedbfef-b07a-4a8d-893b-172f1a5331e2/MANIFEST
 -> 185 artifacts

org.apache.beam.sdk.transforms.CombineFnsTest > testComposedCombine 
STANDARD_ERROR
    [grpc-default-executor-54] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - GetManifest for 
/tmp/beam-artifact-staging/combinefnstest0testcomposedcombine-jenkins-1106125611-a9343f8e_1b5d32d4-f333-4810-af1a-f79dd0a79716/MANIFEST
    [grpc-default-executor-54] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - Loading manifest for retrieval token 
/tmp/beam-artifact-staging/combinefnstest0testcomposedcombine-jenkins-1106125611-a9343f8e_1b5d32d4-f333-4810-af1a-f79dd0a79716/MANIFEST
    [grpc-default-executor-54] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - Manifest at 
/tmp/beam-artifact-staging/combinefnstest0testcomposedcombine-jenkins-1106125611-a9343f8e_1b5d32d4-f333-4810-af1a-f79dd0a79716/MANIFEST
 has 185 artifact locations
    [grpc-default-executor-54] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - GetManifest for 
/tmp/beam-artifact-staging/combinefnstest0testcomposedcombine-jenkins-1106125611-a9343f8e_1b5d32d4-f333-4810-af1a-f79dd0a79716/MANIFEST
 -> 185 artifacts
Java HotSpot(TM) 64-Bit Server VM warning: INFO: 
os::commit_memory(0x00007f2af4cfa000, 12288, 0) failed; error='Cannot allocate 
memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: 
os::commit_memory(0x00007f2ab91dd000, 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/ws/src/runners/flink/job-server/hs_err_pid22497.log>
[thread 139821472143104 also had an error]
Java HotSpot(TM) 64-Bit Server VM warning: INFO: 
os::commit_memory(0x00007f358cdfb000, 12288, 0) failed; error='Cannot allocate 
memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: 
os::commit_memory(0x00007f346c4c5000, 12288, 0) failed; error='Cannot allocate 
memory' (errno=12)
[thread 139863133017856 also had an error]
#
# 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/ws/src/runners/flink/job-server/hs_err_pid22500.log>
Could not stop 
org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@3237fd54.
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.CombineFnsTest > testComposedCombine SKIPPED

org.apache.beam.sdk.transforms.ViewTest > 
testMapSideInputWithNonDeterministicKeyCoder SKIPPED

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

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task 
':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> 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 14m 52s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date

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

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org