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/28 14:14:36 UTC

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming #40

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

Changes:

[robertwb] Add argument parsing and filtering to coders microbenchmark.

[robertwb] Missing type declaration in default coder.

[robertwb] Optimize sequence coders.

[robertwb] Restore unicode typing after Py3 changes.

[robertwb] Optimize LengthPrefixCoder.

[robertwb] Optimize WindowedValue encoding.

[robertwb] Optimize IntervalWindow encoding.

------------------------------------------
[...truncated 228.65 MB...]
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (11/16) (a3cbd647b00120a496946170568afa7d) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (11/16) (a3cbd647b00120a496946170568afa7d).
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16) (a3cbd647b00120a496946170568afa7d) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem a3cbd647b00120a496946170568afa7d.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (16/16) (54da546662c0953014764a4e1dffd59e) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (12/16) (81465ce635aa06719dab9025f3e73ed0) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (12/16) (81465ce635aa06719dab9025f3e73ed0).
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16) (81465ce635aa06719dab9025f3e73ed0) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 81465ce635aa06719dab9025f3e73ed0.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (72f394e26fac981c22a08c669c38d362) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (16/16) (5811be90b88c5fa40f84106d1a44ae8e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16) (5dfcb86edb03019996e4dbd806d78842) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16) (5950ea4ce19dd5711eae418f78bccf8d) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (a3cbd647b00120a496946170568afa7d) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (81465ce635aa06719dab9025f3e73ed0) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (4b5963145f737657cdfe3deff16f7221) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (4b5963145f737657cdfe3deff16f7221).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (4b5963145f737657cdfe3deff16f7221) [FINISHED]
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 4b5963145f737657cdfe3deff16f7221.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (8083ee48141526fe264cdd1c2753132f) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (8083ee48141526fe264cdd1c2753132f).
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (e3233e52e4c1d9877b9535b860324e08) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (e3233e52e4c1d9877b9535b860324e08).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (8083ee48141526fe264cdd1c2753132f) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (7553b7ea8a7b604f095407a4511acb9d) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (7553b7ea8a7b604f095407a4511acb9d).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (7553b7ea8a7b604f095407a4511acb9d) [FINISHED]
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 8083ee48141526fe264cdd1c2753132f.
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 7553b7ea8a7b604f095407a4511acb9d.
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (e3233e52e4c1d9877b9535b860324e08) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16) (d3d5950d7e5f3faaf4b05c0caf512ea5) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16) (d3d5950d7e5f3faaf4b05c0caf512ea5).
    [ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (15/16) (f8ba69000f80a066c8a90afe634f4d77) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16) (d3d5950d7e5f3faaf4b05c0caf512ea5) [FINISHED]
    [ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (15/16) (f8ba69000f80a066c8a90afe634f4d77).
    [ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (4/16) (271cf87aafde0b3e6a8d93e85f31809a) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (4/16) (271cf87aafde0b3e6a8d93e85f31809a).
    [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 ToKeyedWorkItem e3233e52e4c1d9877b9535b860324e08.
    [ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) (f8ba69000f80a066c8a90afe634f4d77) [FINISHED]
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 d3d5950d7e5f3faaf4b05c0caf512ea5.
    [ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16) (271cf87aafde0b3e6a8d93e85f31809a) [FINISHED]
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (9/16) (ab1fcd1d62fdc440b79193757ef3b815) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (9/16) (ab1fcd1d62fdc440b79193757ef3b815).
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (ab1fcd1d62fdc440b79193757ef3b815) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (4b5963145f737657cdfe3deff16f7221) switched from RUNNING to FINISHED.
    [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 ToKeyedWorkItem f8ba69000f80a066c8a90afe634f4d77.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16) (2cc084e1bca9398bb9b4c14d99851fcd) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16) (2cc084e1bca9398bb9b4c14d99851fcd).
    [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 ToKeyedWorkItem 271cf87aafde0b3e6a8d93e85f31809a.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16) (2cc084e1bca9398bb9b4c14d99851fcd) [FINISHED]
    [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 ToKeyedWorkItem ab1fcd1d62fdc440b79193757ef3b815.
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 2cc084e1bca9398bb9b4c14d99851fcd.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (8083ee48141526fe264cdd1c2753132f) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (5/16) (a89fe46803d3e28d0e45bc4d13a6d423) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (5/16) (a89fe46803d3e28d0e45bc4d13a6d423).
    [ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16) (a89fe46803d3e28d0e45bc4d13a6d423) [FINISHED]
    [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 ToKeyedWorkItem a89fe46803d3e28d0e45bc4d13a6d423.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (7553b7ea8a7b604f095407a4511acb9d) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (e3233e52e4c1d9877b9535b860324e08) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16) (d3d5950d7e5f3faaf4b05c0caf512ea5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (f8ba69000f80a066c8a90afe634f4d77) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (271cf87aafde0b3e6a8d93e85f31809a) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (ab1fcd1d62fdc440b79193757ef3b815) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (8aec263b3696e1bc9ef7220a7aabeefa) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (8aec263b3696e1bc9ef7220a7aabeefa).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (8aec263b3696e1bc9ef7220a7aabeefa) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (5/16) (2cc084e1bca9398bb9b4c14d99851fcd) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 8aec263b3696e1bc9ef7220a7aabeefa.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (a89fe46803d3e28d0e45bc4d13a6d423) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (f0247117c4531a62838c0911e56ff788) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (f0247117c4531a62838c0911e56ff788).
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (f0247117c4531a62838c0911e56ff788) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (8aec263b3696e1bc9ef7220a7aabeefa) switched from RUNNING to FINISHED.
    [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 ToKeyedWorkItem f0247117c4531a62838c0911e56ff788.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (f0247117c4531a62838c0911e56ff788) switched from RUNNING to FINISHED.
    [grpc-default-executor-119] WARN org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not supported in the current execution environment. 
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (dc27fbfa089356ef4d383ef844f1c368) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (dc27fbfa089356ef4d383ef844f1c368).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (dc27fbfa089356ef4d383ef844f1c368) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 dc27fbfa089356ef4d383ef844f1c368.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (51589cff5c7f30ac39f783baaf5d04e3) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (51589cff5c7f30ac39f783baaf5d04e3).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (51589cff5c7f30ac39f783baaf5d04e3) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 51589cff5c7f30ac39f783baaf5d04e3.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (dc27fbfa089356ef4d383ef844f1c368) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (c31f5e751bf1ca60891f523c65c8793f) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (c31f5e751bf1ca60891f523c65c8793f).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (c31f5e751bf1ca60891f523c65c8793f) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (51589cff5c7f30ac39f783baaf5d04e3) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 c31f5e751bf1ca60891f523c65c8793f.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (532fef831f0791341233a6a9fa69799e) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (b1c6b5b1577f49b610f1674ddcb8f8fc) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (532fef831f0791341233a6a9fa69799e).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (b1c6b5b1577f49b610f1674ddcb8f8fc).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (532fef831f0791341233a6a9fa69799e) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (b1c6b5b1577f49b610f1674ddcb8f8fc) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 532fef831f0791341233a6a9fa69799e.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (c31f5e751bf1ca60891f523c65c8793f) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 b1c6b5b1577f49b610f1674ddcb8f8fc.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (d032ad6ff2d2521c0f97337c59966435) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (d032ad6ff2d2521c0f97337c59966435).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (532fef831f0791341233a6a9fa69799e) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (d032ad6ff2d2521c0f97337c59966435) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 d032ad6ff2d2521c0f97337c59966435.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (b1c6b5b1577f49b610f1674ddcb8f8fc) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (af13a8cf263fa9ddb2ea3ba386a9c2b3) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (af13a8cf263fa9ddb2ea3ba386a9c2b3).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (af13a8cf263fa9ddb2ea3ba386a9c2b3) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (d032ad6ff2d2521c0f97337c59966435) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 af13a8cf263fa9ddb2ea3ba386a9c2b3.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (e189cbe80812811df339c28420400242) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (e189cbe80812811df339c28420400242).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (e189cbe80812811df339c28420400242) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (af13a8cf263fa9ddb2ea3ba386a9c2b3) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 e189cbe80812811df339c28420400242.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (e189cbe80812811df339c28420400242) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (14ccd0be23f2bbe1a4b2d8d96f6ae18c) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (14ccd0be23f2bbe1a4b2d8d96f6ae18c).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (14ccd0be23f2bbe1a4b2d8d96f6ae18c) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 14ccd0be23f2bbe1a4b2d8d96f6ae18c.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (b4c686d9b6a97f76a38c6cbc465a259a) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (b4c686d9b6a97f76a38c6cbc465a259a).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (b4c686d9b6a97f76a38c6cbc465a259a) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (14ccd0be23f2bbe1a4b2d8d96f6ae18c) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 b4c686d9b6a97f76a38c6cbc465a259a.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (b4c686d9b6a97f76a38c6cbc465a259a) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (34bc3af605fe1c4529889fb2d6390d95) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (38a20ddc46d49e98e6447539e1b9ceaf) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (319eb495fd33fd2f8971a546143ba12b) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (34bc3af605fe1c4529889fb2d6390d95).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (38a20ddc46d49e98e6447539e1b9ceaf).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (319eb495fd33fd2f8971a546143ba12b).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (34bc3af605fe1c4529889fb2d6390d95) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (38a20ddc46d49e98e6447539e1b9ceaf) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (319eb495fd33fd2f8971a546143ba12b) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 34bc3af605fe1c4529889fb2d6390d95.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 38a20ddc46d49e98e6447539e1b9ceaf.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (0a3098e2e5c7f28d8eb540375c746358) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (0a3098e2e5c7f28d8eb540375c746358).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (0a3098e2e5c7f28d8eb540375c746358) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 319eb495fd33fd2f8971a546143ba12b.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (34bc3af605fe1c4529889fb2d6390d95) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 0a3098e2e5c7f28d8eb540375c746358.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (38a20ddc46d49e98e6447539e1b9ceaf) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (319eb495fd33fd2f8971a546143ba12b) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (0a3098e2e5c7f28d8eb540375c746358) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (a06cb0cb3837a166537232b5dad319bb) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (a06cb0cb3837a166537232b5dad319bb).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (a06cb0cb3837a166537232b5dad319bb) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 a06cb0cb3837a166537232b5dad319bb.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (a06cb0cb3837a166537232b5dad319bb) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (6452143d9eee9b39a73ea3423573a267) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (6452143d9eee9b39a73ea3423573a267).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (6452143d9eee9b39a73ea3423573a267) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 6452143d9eee9b39a73ea3423573a267.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (6452143d9eee9b39a73ea3423573a267) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1128141415-85beb083 (6b26b9391b066c72212ab6b6614fa31e) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 6b26b9391b066c72212ab6b6614fa31e.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 6b26b9391b066c72212ab6b6614fa31e reached globally terminal state FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1128141415-85beb083(6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 6b26b9391b066c72212ab6b6614fa31e.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection d68111dd6b13fb7cabcb681716147bd9: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 82ebb6cbc6dd7202d733fe1f570d48cf@akka://flink/user/jobmanager_261 for job 6b26b9391b066c72212ab6b6614fa31e from the resource manager.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
    [flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 6b26b9391b066c72212ab6b6614fa31e with leader id 82ebb6cbc6dd7202d733fe1f570d48cf lost leadership.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher7c751c57-ce74-4aa4-b6c4-adbf41ad7f5c.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher7c751c57-ce74-4aa4-b6c4-adbf41ad7f5c.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{7eb7f5f367d585cad15120a2765dd376}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{6381be1762fff7bd7a243a338d4a4685}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2bee5d8ad49f51af310af9489bb53932}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher7c751c57-ce74-4aa4-b6c4-adbf41ad7f5c.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{8ea4a63bbacd84cd76abeb868ff6938d}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{aaeeb4d8861649d01019d51bf8ff7f58}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a85c28af8fb5f6b599e51dc9812d9603}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{63f8c3477766f8262e2616084405b363}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{f37de117cb40a6a4f110548520ac82fb}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{74f326804fe661a10be77b423a8ca6e3}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b29a3b0badd8537a41fbf9cc08858b6a}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{e07ea698f87600848886d65e44439820}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b7b1c0447138487b035342b32c2f03d8}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{6d681ff5a1adc5604ee9b293f46aa6f3}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{3ad323077fcd6d55d70ee0473b7e96df}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{aa19d3d58ff4f50e68603aa421cfc122}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{9f5227d859fbc04b2db85582b05e3cd8}, jobId: 6b26b9391b066c72212ab6b6614fa31e).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 6b26b9391b066c72212ab6b6614fa31e from job leader monitoring.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 6b26b9391b066c72212ab6b6614fa31e.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-46450006-7106-4a13-ab20-01910ca057a6
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
    [ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:43217
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 6484 msecs
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@605d0ebf
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1128141415-85beb083_88f47a14-1801-4180-954f-be4cb351db3d/MANIFEST has 186 artifact locations
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1128141415-85beb083_88f47a14-1801-4180-954f-be4cb351db3d/
    [pool-22513-thread-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:44303
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:46109

Gradle Test Executor 1 finished executing tests.

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming

197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.515 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.969 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>

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

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>

* 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 34m 7s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

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

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

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming #42

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

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

Changes:

[scott] [BEAM-6100] Collect metrics properly in Load tests (#7087)

------------------------------------------
[...truncated 229.03 MB...]
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (11/16) (bab5d5aa3c2f570d214419cefe35d654) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (11/16) (bab5d5aa3c2f570d214419cefe35d654).
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 2ecf63114ffe8c5bc23f4f1281ee3189.
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16) (bab5d5aa3c2f570d214419cefe35d654) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (10/16) (89856fe4cdef8ecf49892c28878f3743) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (10/16) (89856fe4cdef8ecf49892c28878f3743).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (10/16) (89856fe4cdef8ecf49892c28878f3743) [FINISHED]
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 661c4843832c3efd403147c18e3df0d7.
    [ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (13/16) (24a8591a944467b46a666f08409b5b96) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (13/16) (24a8591a944467b46a666f08409b5b96).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16) (46acd0359bf63ea2af1d16e67d5bf653) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16) (46acd0359bf63ea2af1d16e67d5bf653).
    [ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) (24a8591a944467b46a666f08409b5b96) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16) (46acd0359bf63ea2af1d16e67d5bf653) [FINISHED]
    [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 ToKeyedWorkItem bab5d5aa3c2f570d214419cefe35d654.
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 89856fe4cdef8ecf49892c28878f3743.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16) (2ecf63114ffe8c5bc23f4f1281ee3189) switched from RUNNING to FINISHED.
    [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 ToKeyedWorkItem 24a8591a944467b46a666f08409b5b96.
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 46acd0359bf63ea2af1d16e67d5bf653.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (12/16) (635c0a203ffd6b33952ec5ffbc067cbd) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (12/16) (635c0a203ffd6b33952ec5ffbc067cbd).
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16) (635c0a203ffd6b33952ec5ffbc067cbd) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16) (661c4843832c3efd403147c18e3df0d7) switched from RUNNING to FINISHED.
    [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 ToKeyedWorkItem 635c0a203ffd6b33952ec5ffbc067cbd.
    [ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (10/16) (b18a0d0c1a9467275cecf2952a96f464) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (10/16) (b18a0d0c1a9467275cecf2952a96f464).
    [ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16) (b18a0d0c1a9467275cecf2952a96f464) [FINISHED]
    [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 ToKeyedWorkItem b18a0d0c1a9467275cecf2952a96f464.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (bab5d5aa3c2f570d214419cefe35d654) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (10/16) (89856fe4cdef8ecf49892c28878f3743) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (24a8591a944467b46a666f08409b5b96) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (5fac8f545ca3698faa9495377974bb3c) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (5fac8f545ca3698faa9495377974bb3c).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (5fac8f545ca3698faa9495377974bb3c) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16) (46acd0359bf63ea2af1d16e67d5bf653) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (15/16) (4dffcbe2f9a5fc632f43cf3f29a0d1c7) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (15/16) (4dffcbe2f9a5fc632f43cf3f29a0d1c7).
    [ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) (4dffcbe2f9a5fc632f43cf3f29a0d1c7) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (635c0a203ffd6b33952ec5ffbc067cbd) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (05cfcf5b4fceebebd024ee1b0f15d00f) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (05cfcf5b4fceebebd024ee1b0f15d00f).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (05cfcf5b4fceebebd024ee1b0f15d00f) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (10/16) (b18a0d0c1a9467275cecf2952a96f464) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 5fac8f545ca3698faa9495377974bb3c.
    [ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (14/16) (7357dc8056756dcef2f98d1a3073829a) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (14/16) (7357dc8056756dcef2f98d1a3073829a).
    [ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (7357dc8056756dcef2f98d1a3073829a) [FINISHED]
    [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 ToKeyedWorkItem 4dffcbe2f9a5fc632f43cf3f29a0d1c7.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (16/16) (989e5a393953322d66e9cdb281709660) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 05cfcf5b4fceebebd024ee1b0f15d00f.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (16/16) (989e5a393953322d66e9cdb281709660).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (16/16) (989e5a393953322d66e9cdb281709660) [FINISHED]
    [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 ToKeyedWorkItem 7357dc8056756dcef2f98d1a3073829a.
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 989e5a393953322d66e9cdb281709660.
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (16/16) (c987ff1175f880792546a1d17b503de3) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (16/16) (c987ff1175f880792546a1d17b503de3).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (8b5f92c3cceefed5ffa83715f169cc3f) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16) (c987ff1175f880792546a1d17b503de3) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (8b5f92c3cceefed5ffa83715f169cc3f).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (8b5f92c3cceefed5ffa83715f169cc3f) [FINISHED]
    [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 ToKeyedWorkItem c987ff1175f880792546a1d17b503de3.
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 8b5f92c3cceefed5ffa83715f169cc3f.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (5fac8f545ca3698faa9495377974bb3c) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (4dffcbe2f9a5fc632f43cf3f29a0d1c7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (05cfcf5b4fceebebd024ee1b0f15d00f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (7357dc8056756dcef2f98d1a3073829a) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (16/16) (989e5a393953322d66e9cdb281709660) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (16/16) (c987ff1175f880792546a1d17b503de3) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (3da3458ebe87d93705744af9ea8ac8af) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (3da3458ebe87d93705744af9ea8ac8af).
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (3da3458ebe87d93705744af9ea8ac8af) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (8b5f92c3cceefed5ffa83715f169cc3f) switched from RUNNING to FINISHED.
    [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 ToKeyedWorkItem 3da3458ebe87d93705744af9ea8ac8af.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (3da3458ebe87d93705744af9ea8ac8af) switched from RUNNING to FINISHED.
    [grpc-default-executor-119] WARN org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not supported in the current execution environment. 
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (cc5a535a30ddb4d06d3d6dca41950dab) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (cc5a535a30ddb4d06d3d6dca41950dab).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (cc5a535a30ddb4d06d3d6dca41950dab) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 cc5a535a30ddb4d06d3d6dca41950dab.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (e94aa59affc9e9a3ea83139f6fcf3723) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (e94aa59affc9e9a3ea83139f6fcf3723).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (2d910098aeb61743eeb496060806419e) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (2d910098aeb61743eeb496060806419e).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (e94aa59affc9e9a3ea83139f6fcf3723) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (2d910098aeb61743eeb496060806419e) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (cc5a535a30ddb4d06d3d6dca41950dab) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 e94aa59affc9e9a3ea83139f6fcf3723.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (ca2774c98ea59e9ba09a981883f2555f) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (ca2774c98ea59e9ba09a981883f2555f).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (ca2774c98ea59e9ba09a981883f2555f) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 2d910098aeb61743eeb496060806419e.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 ca2774c98ea59e9ba09a981883f2555f.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (e94aa59affc9e9a3ea83139f6fcf3723) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (c76fe1fac21d106d25201562c1f6b4e8) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (c76fe1fac21d106d25201562c1f6b4e8).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (c76fe1fac21d106d25201562c1f6b4e8) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 c76fe1fac21d106d25201562c1f6b4e8.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (2d910098aeb61743eeb496060806419e) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (65c3348824f61db9db62aec1872fac1b) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (ca2774c98ea59e9ba09a981883f2555f) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (65c3348824f61db9db62aec1872fac1b).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (65c3348824f61db9db62aec1872fac1b) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (e6596a0baa6cab9fb34f4b25fa89abbb) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (238ac6ef889c68725f012ef4959a9b81) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (e6596a0baa6cab9fb34f4b25fa89abbb).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (238ac6ef889c68725f012ef4959a9b81).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (e6596a0baa6cab9fb34f4b25fa89abbb) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (238ac6ef889c68725f012ef4959a9b81) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (c76fe1fac21d106d25201562c1f6b4e8) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 65c3348824f61db9db62aec1872fac1b.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (61054b86ebe09dbcaae287c661141462) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (84e2debcb7b441dc18adb4455eb85e06) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (61054b86ebe09dbcaae287c661141462).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (84e2debcb7b441dc18adb4455eb85e06).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (61054b86ebe09dbcaae287c661141462) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (84e2debcb7b441dc18adb4455eb85e06) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 e6596a0baa6cab9fb34f4b25fa89abbb.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 238ac6ef889c68725f012ef4959a9b81.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (65c3348824f61db9db62aec1872fac1b) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 84e2debcb7b441dc18adb4455eb85e06.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 61054b86ebe09dbcaae287c661141462.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (e6596a0baa6cab9fb34f4b25fa89abbb) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (238ac6ef889c68725f012ef4959a9b81) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (7dc8ecb399e8bcfbe9988e8652a526ae) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (7dc8ecb399e8bcfbe9988e8652a526ae).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (7dc8ecb399e8bcfbe9988e8652a526ae) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 7dc8ecb399e8bcfbe9988e8652a526ae.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (84e2debcb7b441dc18adb4455eb85e06) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (61054b86ebe09dbcaae287c661141462) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (7dc8ecb399e8bcfbe9988e8652a526ae) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (76ab554731cdf434adc0cf6609994cbc) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (76ab554731cdf434adc0cf6609994cbc).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (76ab554731cdf434adc0cf6609994cbc) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 76ab554731cdf434adc0cf6609994cbc.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (a0834085b95675ba0f1c04ffd76624f2) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (a0834085b95675ba0f1c04ffd76624f2).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (a0834085b95675ba0f1c04ffd76624f2) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 a0834085b95675ba0f1c04ffd76624f2.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (76ab554731cdf434adc0cf6609994cbc) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (a0834085b95675ba0f1c04ffd76624f2) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (bcd021b2f65fbc26e5409d977a210796) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (15a4c6e194018898f26abb06fb0a5c38) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (15a4c6e194018898f26abb06fb0a5c38).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (bcd021b2f65fbc26e5409d977a210796).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (15a4c6e194018898f26abb06fb0a5c38) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (bcd021b2f65fbc26e5409d977a210796) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 bcd021b2f65fbc26e5409d977a210796.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 15a4c6e194018898f26abb06fb0a5c38.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (bcd021b2f65fbc26e5409d977a210796) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (15a4c6e194018898f26abb06fb0a5c38) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (f54f6ff6fc1e16f52b7db35006a0b2c1) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (f54f6ff6fc1e16f52b7db35006a0b2c1).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (f54f6ff6fc1e16f52b7db35006a0b2c1) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 f54f6ff6fc1e16f52b7db35006a0b2c1.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (f54f6ff6fc1e16f52b7db35006a0b2c1) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1128174528-129b3a7d (ac6ef64c6a2acefc992ac5aba81fd9ec) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job ac6ef64c6a2acefc992ac5aba81fd9ec.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job ac6ef64c6a2acefc992ac5aba81fd9ec reached globally terminal state FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1128174528-129b3a7d(ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job ac6ef64c6a2acefc992ac5aba81fd9ec.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 6d024ff0f64c04e73c9d6109f683b021: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 8e363cd5216daf60084ae9c38b074a90@akka://flink/user/jobmanager_261 for job ac6ef64c6a2acefc992ac5aba81fd9ec from the resource manager.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job ac6ef64c6a2acefc992ac5aba81fd9ec with leader id 8e363cd5216daf60084ae9c38b074a90 lost leadership.
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
    [flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher8783e3c9-1848-4d7a-ba62-5b2af54ba703.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher8783e3c9-1848-4d7a-ba62-5b2af54ba703.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{84bea028b5592a810108fcf1230c49d2}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{498ff1cd1896caccc4310a8f937cc193}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{ac773151544e189334e6f6ccf7472491}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{65e45b6bfef162058a084e8e5e5cee19}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{1dad9cd11aa849556a3d6d3aaf12b68d}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{5da60e0e7febf614dd2995eac5e193c4}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{839d131de22bfea388bece1f702156b1}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{1fcaa912e5fb4d68d16259d049ca236a}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b5c956d0939919f7e6f655cf8326e2ac}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a06f211b8d95ed19c3541ed786a97c35}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{020528666e9ece1653a4e16f0e100922}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{4637a28f99feae13b57b1f9a8d5f0c6f}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{70c77dde6b00e51fe9bd15d1ad10db7a}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{c24c0d313ce9be47f06c03e33f6b2ea0}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{0bbac25ca958dbb5ff4ff1e638df01be}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2f3fdbb2b7bee23f327273690047033b}, jobId: ac6ef64c6a2acefc992ac5aba81fd9ec).
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job ac6ef64c6a2acefc992ac5aba81fd9ec from job leader monitoring.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job ac6ef64c6a2acefc992ac5aba81fd9ec.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job ac6ef64c6a2acefc992ac5aba81fd9ec.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher8783e3c9-1848-4d7a-ba62-5b2af54ba703.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-f7e995b8-3c8b-426d-9e83-791137561ea9
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [ForkJoinPool.commonPool-worker-4] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:33227
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 6191 msecs
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@f8d72f89
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1128174528-129b3a7d_6f9109f5-0f29-4fe9-b052-d158aa70ec96/MANIFEST has 186 artifact locations
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1128174528-129b3a7d_6f9109f5-0f29-4fe9-b052-d158aa70ec96/
    [pool-22513-thread-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:37673
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:42485

Gradle Test Executor 1 finished executing tests.

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming

197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.531 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.951 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>

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

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>

* 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 36m 42s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

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

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

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming #41

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

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

Changes:

[cyturel] BEAM-6134: MongoDbIO add support for projection

------------------------------------------
[...truncated 228.71 MB...]
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (9/16) (472a3bfdc1e6c88748f36ba6d5d31bb0) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (9/16) (472a3bfdc1e6c88748f36ba6d5d31bb0).
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (472a3bfdc1e6c88748f36ba6d5d31bb0) [FINISHED]
    [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 ToKeyedWorkItem 472a3bfdc1e6c88748f36ba6d5d31bb0.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (9/16) (77b77399179c992e3f577a31d31ca28c) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (6b4824fb75b29c4122b1221f5a2702a7) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (9fe81bb091aab2057bc56f984fd8e6bb) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (9fe81bb091aab2057bc56f984fd8e6bb).
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (9fe81bb091aab2057bc56f984fd8e6bb) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (7be8efa7181a3a9dd0442c2a3c824d57) switched from RUNNING to FINISHED.
    [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 ToKeyedWorkItem 9fe81bb091aab2057bc56f984fd8e6bb.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (74648cef2b72cdf83dca3f89e2c64edc) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (472a3bfdc1e6c88748f36ba6d5d31bb0) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (9fe81bb091aab2057bc56f984fd8e6bb) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16) (27bcd6bcdbb47499245299ee68993742) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16) (27bcd6bcdbb47499245299ee68993742).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16) (27bcd6bcdbb47499245299ee68993742) [FINISHED]
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/16) (e4b0ec86d13ae2bd54ad369a8f695a75) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/16) (e4b0ec86d13ae2bd54ad369a8f695a75).
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 27bcd6bcdbb47499245299ee68993742.
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16) (e4b0ec86d13ae2bd54ad369a8f695a75) [FINISHED]
    [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 ToKeyedWorkItem e4b0ec86d13ae2bd54ad369a8f695a75.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (1/16) (27bcd6bcdbb47499245299ee68993742) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (e4b0ec86d13ae2bd54ad369a8f695a75) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16) (17dc0fd058be30528818ee0b40007351) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16) (17dc0fd058be30528818ee0b40007351).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (6/16) (a8e9dee07b49545ea9a4f48510397dc0) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (6/16) (a8e9dee07b49545ea9a4f48510397dc0).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16) (17dc0fd058be30528818ee0b40007351) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (6/16) (a8e9dee07b49545ea9a4f48510397dc0) [FINISHED]
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 17dc0fd058be30528818ee0b40007351.
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (11/16) (040fc10772ff76b57a809abd10f9bd0e) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (11/16) (040fc10772ff76b57a809abd10f9bd0e).
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16) (040fc10772ff76b57a809abd10f9bd0e) [FINISHED]
    [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 PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 a8e9dee07b49545ea9a4f48510397dc0.
    [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 ToKeyedWorkItem 040fc10772ff76b57a809abd10f9bd0e.
    [ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (6/16) (fb0ff208cf094f96a5383f8562914ab5) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16) (74a562b014c70952b9289deef90e323c) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (6/16) (fb0ff208cf094f96a5383f8562914ab5).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16) (74a562b014c70952b9289deef90e323c).
    [ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) (fb0ff208cf094f96a5383f8562914ab5) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16) (74a562b014c70952b9289deef90e323c) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (e65055170b2d1452948693d819e85d3a) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (e65055170b2d1452948693d819e85d3a).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16) (17dc0fd058be30528818ee0b40007351) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (e65055170b2d1452948693d819e85d3a) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem fb0ff208cf094f96a5383f8562914ab5.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (6/16) (a8e9dee07b49545ea9a4f48510397dc0) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 74a562b014c70952b9289deef90e323c.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (cb9d2819348b89c63990bac9bd55aac8) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (040fc10772ff76b57a809abd10f9bd0e) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (cb9d2819348b89c63990bac9bd55aac8).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (cb9d2819348b89c63990bac9bd55aac8) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 e65055170b2d1452948693d819e85d3a.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (fb0ff208cf094f96a5383f8562914ab5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 cb9d2819348b89c63990bac9bd55aac8.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (12/16) (74a562b014c70952b9289deef90e323c) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (12/16) (116dae5e2b63bcc219b6459562abbf76) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (12/16) (116dae5e2b63bcc219b6459562abbf76).
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16) (116dae5e2b63bcc219b6459562abbf76) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 116dae5e2b63bcc219b6459562abbf76.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (e65055170b2d1452948693d819e85d3a) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (cb9d2819348b89c63990bac9bd55aac8) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (cb14fced348ceffbd2151b1f74a83e1d) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (cb14fced348ceffbd2151b1f74a83e1d).
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (cb14fced348ceffbd2151b1f74a83e1d) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (116dae5e2b63bcc219b6459562abbf76) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (14/16) (3b792e8bebdd52b05a4c26d0297b2b91) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (14/16) (3b792e8bebdd52b05a4c26d0297b2b91).
    [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 ToKeyedWorkItem cb14fced348ceffbd2151b1f74a83e1d.
    [ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (3b792e8bebdd52b05a4c26d0297b2b91) [FINISHED]
    [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 ToKeyedWorkItem 3b792e8bebdd52b05a4c26d0297b2b91.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (cb14fced348ceffbd2151b1f74a83e1d) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (3b792e8bebdd52b05a4c26d0297b2b91) switched from RUNNING to FINISHED.
    [grpc-default-executor-142] WARN org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not supported in the current execution environment. 
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (1c31ea35e4ec1b62e6f7e34e9d808a42) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (1c31ea35e4ec1b62e6f7e34e9d808a42).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (1c31ea35e4ec1b62e6f7e34e9d808a42) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 1c31ea35e4ec1b62e6f7e34e9d808a42.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (3a351c989f3c9f75004a2a31f05cebf3) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (3a351c989f3c9f75004a2a31f05cebf3).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (3a351c989f3c9f75004a2a31f05cebf3) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 3a351c989f3c9f75004a2a31f05cebf3.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (1c31ea35e4ec1b62e6f7e34e9d808a42) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (d17541864aac6ab996df7b6756f1c308) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (d17541864aac6ab996df7b6756f1c308).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (d17541864aac6ab996df7b6756f1c308) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 d17541864aac6ab996df7b6756f1c308.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (3a351c989f3c9f75004a2a31f05cebf3) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (d17541864aac6ab996df7b6756f1c308) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (4d596fbcb0ee6c3d637093925a1c451b) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (4d596fbcb0ee6c3d637093925a1c451b).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (4d596fbcb0ee6c3d637093925a1c451b) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 4d596fbcb0ee6c3d637093925a1c451b.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (f986665953b9549a57bc8e46886c9449) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (595475d4f91a34063870c2cddb13640f) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (f986665953b9549a57bc8e46886c9449).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (595475d4f91a34063870c2cddb13640f).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (f986665953b9549a57bc8e46886c9449) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (595475d4f91a34063870c2cddb13640f) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 f986665953b9549a57bc8e46886c9449.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (ad031843c352d610e1a27a3428f29873) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (ad031843c352d610e1a27a3428f29873).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (ad031843c352d610e1a27a3428f29873) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (5865f7bd5f381f9207b37b66d92f3086) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (5865f7bd5f381f9207b37b66d92f3086).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (5865f7bd5f381f9207b37b66d92f3086) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 595475d4f91a34063870c2cddb13640f.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (4d596fbcb0ee6c3d637093925a1c451b) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 ad031843c352d610e1a27a3428f29873.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (b6e453b22eb6f5174c616790be5d5af0) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (b6e453b22eb6f5174c616790be5d5af0).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (f986665953b9549a57bc8e46886c9449) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (b6e453b22eb6f5174c616790be5d5af0) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 5865f7bd5f381f9207b37b66d92f3086.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (595475d4f91a34063870c2cddb13640f) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 b6e453b22eb6f5174c616790be5d5af0.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (d7c7d727576c3f30986a4c24f384c5de) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (d7c7d727576c3f30986a4c24f384c5de).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (d7c7d727576c3f30986a4c24f384c5de) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 d7c7d727576c3f30986a4c24f384c5de.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (ad031843c352d610e1a27a3428f29873) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (5865f7bd5f381f9207b37b66d92f3086) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (b6e453b22eb6f5174c616790be5d5af0) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (d7c7d727576c3f30986a4c24f384c5de) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (bcce0683e276152757d607d781c8c39a) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (bcce0683e276152757d607d781c8c39a).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (bcce0683e276152757d607d781c8c39a) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 bcce0683e276152757d607d781c8c39a.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (bcce0683e276152757d607d781c8c39a) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (00eddbfdf2631448c758b374eb763db6) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (00eddbfdf2631448c758b374eb763db6).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (00eddbfdf2631448c758b374eb763db6) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 00eddbfdf2631448c758b374eb763db6.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (00eddbfdf2631448c758b374eb763db6) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (ff02c3197126ffd0e541d78ed95d815c) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (ff02c3197126ffd0e541d78ed95d815c).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (ff02c3197126ffd0e541d78ed95d815c) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 ff02c3197126ffd0e541d78ed95d815c.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (ff02c3197126ffd0e541d78ed95d815c) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (95c0bb9474d212e339e1c8d95261f0f1) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (95c0bb9474d212e339e1c8d95261f0f1).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (95c0bb9474d212e339e1c8d95261f0f1) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 95c0bb9474d212e339e1c8d95261f0f1.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (3d1cbc330b9ae4f7e9334facff25258d) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (3d1cbc330b9ae4f7e9334facff25258d).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (3d1cbc330b9ae4f7e9334facff25258d) [FINISHED]
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 3d1cbc330b9ae4f7e9334facff25258d.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (95c0bb9474d212e339e1c8d95261f0f1) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (60a1684312d5023f1df86c848e999265) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (60a1684312d5023f1df86c848e999265).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (60a1684312d5023f1df86c848e999265) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (3d1cbc330b9ae4f7e9334facff25258d) switched from RUNNING to FINISHED.
    [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 PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 60a1684312d5023f1df86c848e999265.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (60a1684312d5023f1df86c848e999265) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1128144911-1e99fc6c (f0b739b5c3b70ddc72b7be55183d1827) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job f0b739b5c3b70ddc72b7be55183d1827.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job f0b739b5c3b70ddc72b7be55183d1827 reached globally terminal state FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1128144911-1e99fc6c(f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 5dee7092c5c63f89a45d2b66082a254b: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f0b739b5c3b70ddc72b7be55183d1827.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager b111d20aee6f6907d0b3c146cb034883@akka://flink/user/jobmanager_261 for job f0b739b5c3b70ddc72b7be55183d1827 from the resource manager.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job f0b739b5c3b70ddc72b7be55183d1827 with leader id b111d20aee6f6907d0b3c146cb034883 lost leadership.
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
    [flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatchercae92db6-ebf9-4900-9b91-c6251262dbb6.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatchercae92db6-ebf9-4900-9b91-c6251262dbb6.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{c65be7661b7770579f0577ae52adc63d}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{4e3d308f02b58af0bce1f3306974e59f}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{4feeee351505f7bf812df880e4690e91}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{465a3597dd86799157ba700fda3fcfb1}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{33160ae6913c79271908d70ca0498d71}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{0ce9948f060261e036bbe5942f16dcb0}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b27a49243031d185a21e72538dde9a4a}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{0639642f58f3fb91fd7fc5eece4ed6b9}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{3b6ad7f9279ab555a76354697e8b5603}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatchercae92db6-ebf9-4900-9b91-c6251262dbb6.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{1bf51c0a1d5c37198f453d1126ddda14}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{0d64cf0c6e8b57e3c106fd60acbf96bb}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{6b464cd4b35626bf38865f83978e2bbc}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{9b066a606235e2fac7345f128c87e124}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{1f5e0c40e496d6a0fe19452e27285d99}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a565a922cae8c8b8d8d5d18cc9880cbf}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{701c932ce7102b431994b7715eb6bc5e}, jobId: f0b739b5c3b70ddc72b7be55183d1827).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job f0b739b5c3b70ddc72b7be55183d1827 from job leader monitoring.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f0b739b5c3b70ddc72b7be55183d1827.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f0b739b5c3b70ddc72b7be55183d1827.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-b1a40d43-9426-40bd-b190-a6d5655f76c5
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
    [ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:42403
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 6372 msecs
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Final accumulator values:
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - __metricscontainers : org.apache.beam.runners.core.metrics.MetricsContainerStepMap@a46b5a35
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1128144911-1e99fc6c_282c96c5-98b9-47bf-b65b-9898a0a24020/MANIFEST has 186 artifact locations
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1128144911-1e99fc6c_282c96c5-98b9-47bf-b65b-9898a0a24020/
    [pool-22513-thread-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:44193
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:45421

Gradle Test Executor 1 finished executing tests.

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming

197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.547 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.915 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>

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

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>

* 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 34m 40s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/2xhpdtxt3kpne

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