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/06 13:24:01 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #232

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

Changes:

[github] Update note on portability status.

------------------------------------------
[...truncated 234.47 MB...]
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (d04258c1ea7f3fc193accafc95c18990) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (9/16) (e3336eafa4171219a7d7a0a261aae1bd) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (d04258c1ea7f3fc193accafc95c18990) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (12/16) (647d56a16777ff4405b81c24cc82bc20) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16) (d04258c1ea7f3fc193accafc95c18990) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16).
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (0628ff05c5981a5ae1cbda8fc80cbe80) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (0628ff05c5981a5ae1cbda8fc80cbe80) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (0628ff05c5981a5ae1cbda8fc80cbe80) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (0628ff05c5981a5ae1cbda8fc80cbe80) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (0628ff05c5981a5ae1cbda8fc80cbe80) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (0628ff05c5981a5ae1cbda8fc80cbe80) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16).
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (5/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (177ad4dfe19b3ad3fecc23c7e33e507d) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (177ad4dfe19b3ad3fecc23c7e33e507d) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (177ad4dfe19b3ad3fecc23c7e33e507d) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (177ad4dfe19b3ad3fecc23c7e33e507d) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (177ad4dfe19b3ad3fecc23c7e33e507d) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (177ad4dfe19b3ad3fecc23c7e33e507d) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) c1507222f8613ddaebd3f9f7594633f6.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (6f43d67add4d416acfacba0610dd9469) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (6f43d67add4d416acfacba0610dd9469) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (6f43d67add4d416acfacba0610dd9469) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (11/16) (c1507222f8613ddaebd3f9f7594633f6) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (6f43d67add4d416acfacba0610dd9469) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16).
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (6f43d67add4d416acfacba0610dd9469) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (6f43d67add4d416acfacba0610dd9469) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 18431b314219dc4e056d9f163ac650a0.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (047b7249f7e07acf0b1b5f9e7d0a5001) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (047b7249f7e07acf0b1b5f9e7d0a5001) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (047b7249f7e07acf0b1b5f9e7d0a5001) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (2/16) (18431b314219dc4e056d9f163ac650a0) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (047b7249f7e07acf0b1b5f9e7d0a5001) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (047b7249f7e07acf0b1b5f9e7d0a5001) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (11/16) (047b7249f7e07acf0b1b5f9e7d0a5001) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 92704ff2b4ea4ea84504e68e04dc8ade.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (f63020820baf7b0d7537a970f05bcc3c) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (f63020820baf7b0d7537a970f05bcc3c) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (f63020820baf7b0d7537a970f05bcc3c) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (2/16) (92704ff2b4ea4ea84504e68e04dc8ade) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (f63020820baf7b0d7537a970f05bcc3c) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (f63020820baf7b0d7537a970f05bcc3c) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (f63020820baf7b0d7537a970f05bcc3c) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 10871dba54863b009ac7c0b752966a96.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0ededdaa825287413db4e78879f2a491) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0ededdaa825287413db4e78879f2a491) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0ededdaa825287413db4e78879f2a491) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (3/16) (10871dba54863b009ac7c0b752966a96) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0ededdaa825287413db4e78879f2a491) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0ededdaa825287413db4e78879f2a491) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/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 Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16) (0ededdaa825287413db4e78879f2a491) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16).
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/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$65/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.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 3910ca79e2dd9c3969d37dbf22fffae0.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (08f9c0dc97bab877897edcee43271528) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (08f9c0dc97bab877897edcee43271528) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (08f9c0dc97bab877897edcee43271528) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (4/16) (3910ca79e2dd9c3969d37dbf22fffae0) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (08f9c0dc97bab877897edcee43271528) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (08f9c0dc97bab877897edcee43271528) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/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-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (08f9c0dc97bab877897edcee43271528) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16).
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (2/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) 4418369e297c1e528a551e48f2a9f619.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (91c59080a249694355deb00d941967c0) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (91c59080a249694355deb00d941967c0) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSource (at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) daeb91b6343fdeeeb0b8a127f09c3724.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (91c59080a249694355deb00d941967c0) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (8/16) (4418369e297c1e528a551e48f2a9f619) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (91c59080a249694355deb00d941967c0) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (91c59080a249694355deb00d941967c0) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse (org.apache.beam.runners.flink.translation.wrappers.ImpulseInputFormat)) (4/16) (daeb91b6343fdeeeb0b8a127f09c3724) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (91c59080a249694355deb00d941967c0) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16).
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (988e5bf35e1f7bdac1c48c8c87bf3632) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (988e5bf35e1f7bdac1c48c8c87bf3632) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/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$66/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$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (988e5bf35e1f7bdac1c48c8c87bf3632) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16).
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (988e5bf35e1f7bdac1c48c8c87bf3632) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (988e5bf35e1f7bdac1c48c8c87bf3632) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (988e5bf35e1f7bdac1c48c8c87bf3632) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (852ea78af51cd04093f18eeb99e55539) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (852ea78af51cd04093f18eeb99e55539) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (852ea78af51cd04093f18eeb99e55539) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at PAssert$65/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (852ea78af51cd04093f18eeb99e55539) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (852ea78af51cd04093f18eeb99e55539) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16) (852ea78af51cd04093f18eeb99e55539) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (4/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name FlatMap (FlatMap at PAssert$66/GroupGlobally/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) exceeded the 80 characters length limit and was truncated.

org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests > testGroupByKeyWithBadEqualsHashCode STANDARD_ERROR
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:35053
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:39633

org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests > testLargeKeys100KB STANDARD_ERROR
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingService started on localhost:46019
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobService started on localhost:46427
    [Test worker] WARN org.apache.beam.sdk.coders.SerializableCoder - Can't verify serialized elements of type BoundedSource have well defined equals method. This may produce incorrect results on some PipelineRunner
    [Test worker] WARN org.apache.beam.sdk.coders.SerializableCoder - Can't verify serialized elements of type BoundedSource have well defined equals method. This may produce incorrect results on some PipelineRunner
    [Test worker] INFO org.apache.beam.runners.reference.PortableRunner - Using job server endpoint: localhost:46427
    [Test worker] INFO org.apache.beam.runners.reference.PortableRunner - PrepareJobResponse: preparation_id: "groupbykeytest0basictests0testlargekeys100kb-jenkins-1106132259-9066e04b_2144c9f9-04c6-4ed9-b971-3f9acce21148"
    artifact_staging_endpoint {
      url: "localhost:46019"
    }
    staging_session_token: "{\"sessionId\":\"groupbykeytest0basictests0testlargekeys100kb-jenkins-1106132259-9066e04b_2144c9f9-04c6-4ed9-b971-3f9acce21148\",\"basePath\":\"/tmp/beam-artifact-staging\"}"

    [Test worker] INFO org.apache.beam.runners.core.construction.ArtifactServiceStager - Staging 185 files (token: {"sessionId":"groupbykeytest0basictests0testlargekeys100kb-jenkins-1106132259-9066e04b_2144c9f9-04c6-4ed9-b971-3f9acce21148","basePath":"/tmp/beam-artifact-staging"})
    [Test worker] INFO org.apache.beam.runners.core.construction.ArtifactServiceStager - Staged 185 files (token: {"sessionId":"groupbykeytest0basictests0testlargekeys100kb-jenkins-1106132259-9066e04b_2144c9f9-04c6-4ed9-b971-3f9acce21148","basePath":"/tmp/beam-artifact-staging"})
    [grpc-default-executor-64] INFO org.apache.beam.runners.flink.FlinkJobInvoker - Invoking job groupbykeytest0basictests0testlargekeys100kb-jenkins-1106132259-9066e04b_a4c9dc50-bf27-4a60-81ba-b621d27206b2
    [grpc-default-executor-64] INFO org.apache.beam.runners.flink.FlinkJobInvocation - Starting job invocation groupbykeytest0basictests0testlargekeys100kb-jenkins-1106132259-9066e04b_a4c9dc50-bf27-4a60-81ba-b621d27206b2
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkJobInvocation - Translating pipeline to Flink program.
    [Test worker] INFO org.apache.beam.runners.reference.PortableRunner - RunJobResponse: job_id: "groupbykeytest0basictests0testlargekeys100kb-jenkins-1106132259-9066e04b_a4c9dc50-bf27-4a60-81ba-b621d27206b2"

    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkExecutionEnvironments - Creating a Batch Execution Environment.
    [flink-runner-job-server] INFO org.apache.flink.api.java.ExecutionEnvironment - The job has 0 registered types and 0 default Kryo serializers
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Flink Mini Cluster
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Metrics Registry
    [flink-runner-job-server] INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter configured, no metrics will be exposed/reported.
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting RPC Service(s)
    [flink-akka.actor.default-dispatcher-3] INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting high-availability services
    [flink-runner-job-server] INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /tmp/blobStore-4f6febd4-c4b5-4415-b703-02191c47ba2f
    [flink-runner-job-server] INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:32779 - max concurrent requests: 50 - max backlog: 1000
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting ResourceManger
    [flink-runner-job-server] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/resourcemanager_373dbeea-8a63-43f1-8566-1933e4fc0bd9 .
    [flink-runner-job-server] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.resourcemanager.StandaloneResourceManager@703eb4be @ akka://flink/user/resourcemanager_373dbeea-8a63-43f1-8566-1933e4fc0bd9
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - ResourceManager akka://flink/user/resourcemanager_373dbeea-8a63-43f1-8566-1933e4fc0bd9 was granted leadership with fencing token be369c9ca1ee568e636dd8ca1f6c400b
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Starting the SlotManager.
    [flink-runner-job-server] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Created BLOB cache storage directory /tmp/blobStore-165066f3-d791-49fb-a4ef-0f0d4b4cb78e
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/resourcemanager_373dbeea-8a63-43f1-8566-1933e4fc0bd9 , session=636dd8ca-1f6c-400b-be36-9c9ca1ee568e
    [flink-runner-job-server] INFO org.apache.flink.runtime.blob.TransientBlobCache - Created BLOB cache storage directory /tmp/blobStore-dd7604ab-d411-43be-8df5-af71689f245a
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting 1 TaskManger(s)
    [flink-runner-job-server] INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Starting TaskManager with ResourceID: b880cd84-798b-4d11-93b2-5f0007fa7a50

org.apache.beam.sdk.transforms.CombineTest$WindowingTests > testSessionsCombine STANDARD_ERROR
    [CHAIN MapPartition (MapPartition at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0) -> FlatMap (FlatMap at Create.TimestampedValues/Create.Values/Read(CreateSource)/Impulse.out/beam:env:docker:v1:0/out.0) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: Create.TimestampedValues/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (1/16)] WARN org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to pull docker image jenkins-docker-apache.bintray.io/beam/java, cause: Received exit code 1 for command 'docker pull jenkins-docker-apache.bintray.io/beam/java'. stderr: Error response from daemon: unknown: Repo 'apache' was not found

org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests > testLargeKeys100KB STANDARD_ERROR
    [flink-runner-job-server] INFO org.apache.flink.runtime.taskexecutor.TaskManagerServices - Temporary file directory '/tmp': total 484 GB, usable 246 GB (50.83% usable)
#
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007fb1b0689000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007fbce69aa000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 12288 bytes for committing reserved memory.
# An error report file with more information is saved as:
# There is insufficient memory for the Java Runtime Environment to continue.
# <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/hs_err_pid24488.log>
# Native memory allocation (mmap) failed to map 12288 bytes for committing reserved memory.
# An error report file with more information is saved as:
# <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/hs_err_pid24489.log>
Could not stop org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@145f1e22.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message [MethodInvocation method: stop()].
	at org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:34)
	at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:31)
	at org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:133)
	at org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:34)
	at org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:73)
	at org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
	at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
	at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
	at java.lang.Thread.run(Thread.java:748)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test Executor 1' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
	at org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:155)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:29)
	... 10 more

org.apache.beam.sdk.transforms.GroupByKeyTest$BasicTests > testLargeKeys100KB SKIPPED

org.apache.beam.sdk.transforms.CombineTest$WindowingTests > testSessionsCombine SKIPPED

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

FAILURE: Build failed with an exception.

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

Publishing build scan...
https://gradle.com/s/4c7vipbf4dsw4

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