Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #166

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

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

Changes:

[garrettjonesgoogle] Fixing publishing problem introduced in #7197

------------------------------------------
[...truncated 125.74 MB...]
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) 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 (Impulse) 7e8878c0973f4b15eefa2739831b7716.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (7/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (47dc01437d0474a296359684cbb59d1b) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (47dc01437d0474a296359684cbb59d1b) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (47dc01437d0474a296359684cbb59d1b) [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 (Impulse) 2075943ccc98b05af106bcd4d04f5923.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (8/16) (7e8878c0973f4b15eefa2739831b7716) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (47dc01437d0474a296359684cbb59d1b) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (8/16) (2075943ccc98b05af106bcd4d04f5923) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (47dc01437d0474a296359684cbb59d1b) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (3/16) (47dc01437d0474a296359684cbb59d1b) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) 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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16).
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (399c0de22a272c34a034d3430aa96e30) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (399c0de22a272c34a034d3430aa96e30) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (399c0de22a272c34a034d3430aa96e30) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (399c0de22a272c34a034d3430aa96e30) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16).
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (399c0de22a272c34a034d3430aa96e30) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) 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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (399c0de22a272c34a034d3430aa96e30) switched from DEPLOYING to RUNNING.
    [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 (Impulse) 0f3ec4095369a5b221d66a6a92d01253.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f1931bdcbac54d5c3073b765cc3f78c6) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f1931bdcbac54d5c3073b765cc3f78c6) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f1931bdcbac54d5c3073b765cc3f78c6) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (8/16) (0f3ec4095369a5b221d66a6a92d01253) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f1931bdcbac54d5c3073b765cc3f78c6) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f1931bdcbac54d5c3073b765cc3f78c6) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) 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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (f1931bdcbac54d5c3073b765cc3f78c6) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/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 (Impulse) f123add606a5f0871f3abb3e5f32f21f.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (5754b07f6549677f4c3d553d2de69a79) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (5754b07f6549677f4c3d553d2de69a79) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (5754b07f6549677f4c3d553d2de69a79) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (9/16) (f123add606a5f0871f3abb3e5f32f21f) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (5754b07f6549677f4c3d553d2de69a79) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (5754b07f6549677f4c3d553d2de69a79) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (8/16) (5754b07f6549677f4c3d553d2de69a79) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) 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 (Impulse) e39d0b792479c035ec86e8295cc4ec87.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (f2ada3d7f01a6fad07d4d3e78d082ed0) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (f2ada3d7f01a6fad07d4d3e78d082ed0) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (f2ada3d7f01a6fad07d4d3e78d082ed0) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (12/16) (e39d0b792479c035ec86e8295cc4ec87) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (f2ada3d7f01a6fad07d4d3e78d082ed0) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (f2ada3d7f01a6fad07d4d3e78d082ed0) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16).
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) exceeded the 80 characters length limit and was truncated.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (f2ada3d7f01a6fad07d4d3e78d082ed0) switched from DEPLOYING to RUNNING.
    [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 (Impulse) e210d32b920b9188ec46b8589ffe7b2b.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0eeea26105a3803d229a0d0328846dcb) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0eeea26105a3803d229a0d0328846dcb) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0eeea26105a3803d229a0d0328846dcb) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (16/16) (e210d32b920b9188ec46b8589ffe7b2b) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0eeea26105a3803d229a0d0328846dcb) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0eeea26105a3803d229a0d0328846dcb) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0eeea26105a3803d229a0d0328846dcb) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16).
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) 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 (Impulse) 46279ff02baef68cdcd69b5080a7ea5d.
    [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 (Impulse) 6bee437fe8a7488aa1b5b9182d7875a1.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (1fde870a74bc376699a8779dde3b3d7f) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (1fde870a74bc376699a8779dde3b3d7f) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (1fde870a74bc376699a8779dde3b3d7f) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (9/16) (46279ff02baef68cdcd69b5080a7ea5d) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (1fde870a74bc376699a8779dde3b3d7f) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (12/16) (6bee437fe8a7488aa1b5b9182d7875a1) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (1fde870a74bc376699a8779dde3b3d7f) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) 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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16) (1fde870a74bc376699a8779dde3b3d7f) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16).
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (16/16)] WARN org.apache.flink.metrics.MetricGroup - The operator name GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (70c4f56038510e7e09ca39345f389f42) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (70c4f56038510e7e09ca39345f389f42) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (70c4f56038510e7e09ca39345f389f42) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (70c4f56038510e7e09ca39345f389f42) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16).
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (70c4f56038510e7e09ca39345f389f42) switched from DEPLOYING to RUNNING.
    [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 (Impulse) 3a0b00b68bfa7c4289665a881d973936.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (9/16) (70c4f56038510e7e09ca39345f389f42) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (aedbbd3a2c2e0eafb6723a32b4833dae) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (aedbbd3a2c2e0eafb6723a32b4833dae) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (aedbbd3a2c2e0eafb6723a32b4833dae) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSource (Impulse) (12/16) (3a0b00b68bfa7c4289665a881d973936) switched from RUNNING to FINISHED.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (aedbbd3a2c2e0eafb6723a32b4833dae) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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 [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) 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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16).
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (aedbbd3a2c2e0eafb6723a32b4833dae) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (aedbbd3a2c2e0eafb6723a32b4833dae) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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 [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0388db6806ee30b8e02416459f6a7a38) switched from CREATED to DEPLOYING.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0388db6806ee30b8e02416459f6a7a38) [DEPLOYING]
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0388db6806ee30b8e02416459f6a7a38) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/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: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0388db6806ee30b8e02416459f6a7a38) [DEPLOYING].
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0388db6806ee30b8e02416459f6a7a38) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (12/16) (0388db6806ee30b8e02416459f6a7a38) switched from DEPLOYING to RUNNING.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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 [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateMainInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateMainInput/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: CreateMainInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]PAssert$55/GroupGlobally/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: PAssert$55/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$55/GroupGlobally/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) exceeded the 80 characters length limit and was truncated.
    [CHAIN MapPartition (MapPartition at [4]CreateSideInput/Create.Values/Read(CreateSource)/{ParDo(SplitBoundedSource), Reshuffle.ViaRandomKey}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at GroupCombine: CreateSideInput/Create.Values/Read(CreateSource)/Reshuffle.ViaRandomKey/Reshuffle/GroupByKey) -> Map (Key Extractor) (13/16)] WARN org.apache.beam.runners.fnexecution.environment.DockerCommand - Unable to pull docker image jenkins-docker-apache.bintray.io/beam/java, cause: Received exit code 1 for command 'docker pull jenkins-docker-apache.bintray.io/beam/java'. stderr: Error response from daemon: unknown: Repo 'apache' was not found
    [grpc-default-executor-261] ERROR org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Failed to handle for unknown endpoint
    [grpc-default-executor-266] WARN org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client failed unexpectedly.
    org.apache.beam.vendor.grpc.v1_13_1.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:272)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    org.apache.beam.vendor.grpc.v1_13_1.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:272)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    [grpc-default-executor-266] WARN org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client failed to be complete.
    org.apache.beam.vendor.grpc.v1_13_1.io.grpc.StatusRuntimeException: CANCELLED: call already cancelled
    Dec 12, 2018 9:15:46 PM org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor run
    SEVERE: Exception while executing runnable org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed@1cd262f4
    org.apache.beam.vendor.grpc.v1_13_1.io.grpc.StatusRuntimeException: CANCELLED: call already cancelled
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
    	at org.apache.beam.runners.fnexecution.state.GrpcStateService$Inbound.onError(GrpcStateService.java:145)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)

    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
    	at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.completeIfNotNull(GrpcLoggingService.java:78)
    	at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.access$400(GrpcLoggingService.java:33)
    	at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService$InboundObserver.onError(GrpcLoggingService.java:105)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    [pool-246-thread-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
    [grpc-default-executor-266] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/viewtest0testwindowedsideinputfixedtofixed-jenkins-1212211540-fd113582_162a7a02-aa79-4455-9626-9cca25eac03c/MANIFEST
    [grpc-default-executor-266] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Loading manifest for retrieval token /tmp/beam-artifact-staging/viewtest0testwindowedsideinputfixedtofixed-jenkins-1212211540-fd113582_162a7a02-aa79-4455-9626-9cca25eac03c/MANIFEST
    [grpc-default-executor-266] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/viewtest0testwindowedsideinputfixedtofixed-jenkins-1212211540-fd113582_162a7a02-aa79-4455-9626-9cca25eac03c/MANIFEST has 186 artifact locations
    [grpc-default-executor-266] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - GetManifest for /tmp/beam-artifact-staging/viewtest0testwindowedsideinputfixedtofixed-jenkins-1212211540-fd113582_162a7a02-aa79-4455-9626-9cca25eac03c/MANIFEST -> 186 artifacts
    [grpc-default-executor-262] INFO org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client connected.
    [grpc-default-executor-239] INFO org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService - Beam Fn Control client connected with id 1
    [grpc-default-executor-239] INFO org.apache.beam.fn.harness.FnHarness - Fn Harness started
    [grpc-default-executor-239] INFO org.apache.beam.fn.harness.FnHarness - Entering instruction processing loop
Could not stop org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@43c7a375.
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 3' 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
	at org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:155)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
	at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
	at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:29)
	... 10 more

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

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

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

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> Process 'Gradle Test Executor 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 25m 11s
75 actionable tasks: 74 executed, 1 up-to-date

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

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

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

Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink_Batch #167

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

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


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