You are viewing a plain text version of this content. The canonical link for it is here.

Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/11/29 20:31:36 UTC

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #51

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

Changes:

[robert] [BEAM-6148] ptest support arbitrary runners

[robert] [BEAM-4726] Add heap profiling hook

[robert] [BEAM-3612] Closurize method invocations

------------------------------------------
[...truncated 497.21 MB...]
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (b15f657ba7f98399021110d4e4650dff) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (b15f657ba7f98399021110d4e4650dff) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (b15f657ba7f98399021110d4e4650dff) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at PAssert$144/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-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16).
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16) (8bab6d9faea272db2eeea839f2ec7831) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/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 GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16) (8bab6d9faea272db2eeea839f2ec7831) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/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 GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16) (8bab6d9faea272db2eeea839f2ec7831) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at PAssert$144/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 GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16) (8bab6d9faea272db2eeea839f2ec7831) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16) (8bab6d9faea272db2eeea839f2ec7831) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16) (8bab6d9faea272db2eeea839f2ec7831) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (b114b6365052ff61f4f2cadd9ad043b2) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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 PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (b114b6365052ff61f4f2cadd9ad043b2) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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 PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (b114b6365052ff61f4f2cadd9ad043b2) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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 PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (b114b6365052ff61f4f2cadd9ad043b2) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16) (47d3fd6ca23cd7b0a29659164422e968) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16) (47d3fd6ca23cd7b0a29659164422e968) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (b114b6365052ff61f4f2cadd9ad043b2) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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 PAssert$146/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16) (47d3fd6ca23cd7b0a29659164422e968) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16) (47d3fd6ca23cd7b0a29659164422e968) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16) (47d3fd6ca23cd7b0a29659164422e968) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/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$146/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/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.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (b114b6365052ff61f4f2cadd9ad043b2) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16) (47d3fd6ca23cd7b0a29659164422e968) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16).
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (14/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/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.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16).
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (6eae2a5ae76777fd73049186c6a1bee7) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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 PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (6eae2a5ae76777fd73049186c6a1bee7) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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 PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (6eae2a5ae76777fd73049186c6a1bee7) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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 PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (6eae2a5ae76777fd73049186c6a1bee7) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (6eae2a5ae76777fd73049186c6a1bee7) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (6eae2a5ae76777fd73049186c6a1bee7) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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 PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (20014ad356dce077b9c426a76182a857) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (20014ad356dce077b9c426a76182a857) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16).
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (20014ad356dce077b9c426a76182a857) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (20014ad356dce077b9c426a76182a857) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (20014ad356dce077b9c426a76182a857) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (20014ad356dce077b9c426a76182a857) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at PAssert$145/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.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16).
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (4ac6dba99c4e12c82a33fae1fdba994d) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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 PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (4ac6dba99c4e12c82a33fae1fdba994d) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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 PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (4ac6dba99c4e12c82a33fae1fdba994d) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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 PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (4ac6dba99c4e12c82a33fae1fdba994d) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (4ac6dba99c4e12c82a33fae1fdba994d) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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 PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/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 PAssert$145/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.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (4ac6dba99c4e12c82a33fae1fdba994d) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16).
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (ac0d9e719301afdd23cb7ef45bc570a6) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (ac0d9e719301afdd23cb7ef45bc570a6) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (ac0d9e719301afdd23cb7ef45bc570a6) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (ac0d9e719301afdd23cb7ef45bc570a6) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (ac0d9e719301afdd23cb7ef45bc570a6) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (ac0d9e719301afdd23cb7ef45bc570a6) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at PAssert$145/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.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16).
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (b330a3985f48ed15ce369dd219b7370f) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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 PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (b330a3985f48ed15ce369dd219b7370f) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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 PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (b330a3985f48ed15ce369dd219b7370f) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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 PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (b330a3985f48ed15ce369dd219b7370f) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (b330a3985f48ed15ce369dd219b7370f) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (10/16) (b330a3985f48ed15ce369dd219b7370f) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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 PAssert$146/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$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (b4c895068d50eda5df859aa21d7f31eb) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/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 PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (b4c895068d50eda5df859aa21d7f31eb) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/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 PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (b4c895068d50eda5df859aa21d7f31eb) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/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 PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (b4c895068d50eda5df859aa21d7f31eb) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (c686a93dad4692d6c34db8ed20b37d20) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (b4c895068d50eda5df859aa21d7f31eb) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/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 PAssert$143/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$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/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: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/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 PAssert$143/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.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (b4c895068d50eda5df859aa21d7f31eb) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16).
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/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 PAssert$146/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/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 PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (c686a93dad4692d6c34db8ed20b37d20) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/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 PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (c686a93dad4692d6c34db8ed20b37d20) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/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 PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (c686a93dad4692d6c34db8ed20b37d20) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (c686a93dad4692d6c34db8ed20b37d20) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (6/16) (c686a93dad4692d6c34db8ed20b37d20) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/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 PAssert$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/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: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16).
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (58a846cb4d7fe8ea509083351815f3c6) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (58a846cb4d7fe8ea509083351815f3c6) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (58a846cb4d7fe8ea509083351815f3c6) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (58a846cb4d7fe8ea509083351815f3c6) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (58a846cb4d7fe8ea509083351815f3c6) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at PAssert$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at PAssert$144/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-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (58a846cb4d7fe8ea509083351815f3c6) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16).
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (7be3ffb51e2138061b0be316d2dff47e) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (7be3ffb51e2138061b0be316d2dff47e) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (7be3ffb51e2138061b0be316d2dff47e) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (7be3ffb51e2138061b0be316d2dff47e) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (7be3ffb51e2138061b0be316d2dff47e) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/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$145/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.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16).
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (c57be141f939f42a87a1545b2bed0fef) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (c57be141f939f42a87a1545b2bed0fef) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (c57be141f939f42a87a1545b2bed0fef) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (c10c79dca8d034e562532e077118a1c7) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (c10c79dca8d034e562532e077118a1c7) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (c10c79dca8d034e562532e077118a1c7) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (c10c79dca8d034e562532e077118a1c7) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (c10c79dca8d034e562532e077118a1c7) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at PAssert$146/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$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (c57be141f939f42a87a1545b2bed0fef) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (c57be141f939f42a87a1545b2bed0fef) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/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$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at PAssert$146/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/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$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/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$144/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.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16).
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (3e95601a0bcdd08ec1efb5adbd9504fb) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (3e95601a0bcdd08ec1efb5adbd9504fb) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (3e95601a0bcdd08ec1efb5adbd9504fb) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (3e95601a0bcdd08ec1efb5adbd9504fb) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (3e95601a0bcdd08ec1efb5adbd9504fb) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/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.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (7be3ffb51e2138061b0be316d2dff47e) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16) (c10c79dca8d034e562532e077118a1c7) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (c57be141f939f42a87a1545b2bed0fef) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (3e95601a0bcdd08ec1efb5adbd9504fb) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at GenerateSequence/Read(BoundedCountingSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 2652d74524db801df330346a8a4dcd4e.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 8b4d245a5486d88a7cd29bc97a140bb1.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 77a6a30a7c7f008bf80e6f36c2d6c7ea.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) d61c77d9130897ff4d0d5a55f6d2c5fb.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 532f562c8e80d39b6ee846c347ea19f6.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) c9acfb09e42c048997b239ed65b86f07.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 01ff6fcf538732b5f7f056a9854efaa5.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) c66efa63da7d40bd8af1ae5aba8997c7.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 60e50bc00e83e821cb0f5bca7b950368.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 17262e4028722e6ff8d2e9d482c89d40.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at GenerateSequence/Read(BoundedCountingSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (8/16) (2652d74524db801df330346a8a4dcd4e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (3/16) (8b4d245a5486d88a7cd29bc97a140bb1) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (7/16) (77a6a30a7c7f008bf80e6f36c2d6c7ea) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (6/16) (d61c77d9130897ff4d0d5a55f6d2c5fb) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (10/16) (532f562c8e80d39b6ee846c347ea19f6) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (9/16) (c9acfb09e42c048997b239ed65b86f07) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (2/16) (01ff6fcf538732b5f7f056a9854efaa5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (10/16) (c66efa63da7d40bd8af1ae5aba8997c7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (7/16) (60e50bc00e83e821cb0f5bca7b950368) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (6/16) (17262e4028722e6ff8d2e9d482c89d40) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 5a5ee0c35a2b05a6b082c16325eef2f1.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at GenerateSequence/Read(BoundedCountingSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 18055d13e7cf52b159e3559b6e96d78a.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 595edba05a6878dec483baf9f83deee3.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 3038d374f33fb2f3c6296512b8b7a929.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) df6409219884ae957629ad1abcbd472c.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 0246576eaf043fc76692f59c4f8b3b16.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at GenerateSequence/Read(BoundedCountingSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 73fad17674869f852ef70d89339f5f7e.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 570c26d80450afd83e5f7c5b806507b2.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) ab2a36ba333a2d112c938f5b44b8d267.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at GenerateSequence/Read(BoundedCountingSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) e2aca81a189cfe6cdd10e765611edbc2.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 34aacf9e0a7a2bb232c564f0bc915947.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (13/16) (5a5ee0c35a2b05a6b082c16325eef2f1) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at GenerateSequence/Read(BoundedCountingSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (14/16) (18055d13e7cf52b159e3559b6e96d78a) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (11/16) (595edba05a6878dec483baf9f83deee3) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (13/16) (3038d374f33fb2f3c6296512b8b7a929) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (6/16) (df6409219884ae957629ad1abcbd472c) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$145/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (5/16) (0246576eaf043fc76692f59c4f8b3b16) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at GenerateSequence/Read(BoundedCountingSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (2/16) (73fad17674869f852ef70d89339f5f7e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (9/16) (570c26d80450afd83e5f7c5b806507b2) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (15/16) (ab2a36ba333a2d112c938f5b44b8d267) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at GenerateSequence/Read(BoundedCountingSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (15/16) (e2aca81a189cfe6cdd10e765611edbc2) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (8/16) (34aacf9e0a7a2bb232c564f0bc915947) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 8bc67b0c7a40904a581b737d6c7cfb4b.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 721b78291f41a7c3593c64950c2e04f5.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 1ac2154729a4f6cebe177e6b2f83242b.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$143/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (3/16) (8bc67b0c7a40904a581b737d6c7cfb4b) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (15/16) (721b78291f41a7c3593c64950c2e04f5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$146/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (9/16) (1ac2154729a4f6cebe177e6b2f83242b) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (148b1bab2ea592f0bf08563a69d78ada) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (148b1bab2ea592f0bf08563a69d78ada) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (148b1bab2ea592f0bf08563a69d78ada) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (148b1bab2ea592f0bf08563a69d78ada) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (148b1bab2ea592f0bf08563a69d78ada) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (148b1bab2ea592f0bf08563a69d78ada) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at PAssert$144/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$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$144/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at PAssert$144/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 GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at GenerateSequence/Read(BoundedCountingSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: GenerateSequence/Read(BoundedCountingSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to pull docker image jenkins-docker-apache.bintray.io/beam/java, cause: Received exit code 1 for command 'docker pull jenkins-docker-apache.bintray.io/beam/java'. stderr: Error response from daemon: unknown: Repo 'apache' was not found
    [grpc-default-executor-252] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/windowtest0testnowindowfndoesnotreassignwindows-jenkins-1129203037-77bef3da_e5b71232-7b82-4903-bbd2-f728eb8d3465/MANIFEST
    [grpc-default-executor-252] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Loading manifest for retrieval token /tmp/beam-artifact-staging/windowtest0testnowindowfndoesnotreassignwindows-jenkins-1129203037-77bef3da_e5b71232-7b82-4903-bbd2-f728eb8d3465/MANIFEST
    [grpc-default-executor-252] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/windowtest0testnowindowfndoesnotreassignwindows-jenkins-1129203037-77bef3da_e5b71232-7b82-4903-bbd2-f728eb8d3465/MANIFEST has 186 artifact locations
    [grpc-default-executor-252] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/windowtest0testnowindowfndoesnotreassignwindows-jenkins-1129203037-77bef3da_e5b71232-7b82-4903-bbd2-f728eb8d3465/MANIFEST -> 186 artifacts
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007efc103c7000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)

org.apache.beam.sdk.transforms.windowing.WindowTest > testNoWindowFnDoesNotReassignWindows SKIPPED

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

FAILURE: Build failed with an exception.

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

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

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

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

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

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

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

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

Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink_Batch #52

Posted by Apache Jenkins Server <je...@builds.apache.org>.

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


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