You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/11/29 02:02:46 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming
#47
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/47/display/redirect?page=changes>
Changes:
[ccy] Update Dataflow worker container to beam-master-20181128
------------------------------------------
[...truncated 228.89 MB...]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16) (cdb540123a74fa6acf0660f443e98215) [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 cdb540123a74fa6acf0660f443e98215.
[flink-akka.actor.default-dispatcher-4] 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) (f7cbb5b58a1aa616c39736a30160133e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (10/16) (cdb540123a74fa6acf0660f443e98215) 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) (5b74295dc8a3764835d9119a0c32d1d7) 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) (5b74295dc8a3764835d9119a0c32d1d7).
[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) (5b74295dc8a3764835d9119a0c32d1d7) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16) (e27d9717d75a561114644c067ab95a84) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/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 (13/16) (e27d9717d75a561114644c067ab95a84).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.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/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16) (e27d9717d75a561114644c067ab95a84) [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 5b74295dc8a3764835d9119a0c32d1d7.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/16) (984966846a213505cbf6756c31f8fdcb) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/16) (984966846a213505cbf6756c31f8fdcb).
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16) (984966846a213505cbf6756c31f8fdcb) [FINISHED]
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (13/16) (760e4a76b527daae267b69d35c0a71f2) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (13/16) (760e4a76b527daae267b69d35c0a71f2).
[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 e27d9717d75a561114644c067ab95a84.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) (760e4a76b527daae267b69d35c0a71f2) [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 984966846a213505cbf6756c31f8fdcb.
[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 760e4a76b527daae267b69d35c0a71f2.
[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 (1/16) (5b74295dc8a3764835d9119a0c32d1d7) 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 (13/16) (e27d9717d75a561114644c067ab95a84) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (984966846a213505cbf6756c31f8fdcb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (760e4a76b527daae267b69d35c0a71f2) 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) (d91247b72e93218385d536a8bc3ba27e) 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) (d91247b72e93218385d536a8bc3ba27e).
[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) (d91247b72e93218385d536a8bc3ba27e) [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 d91247b72e93218385d536a8bc3ba27e.
[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) (959882a13e494bf916ba7f9174dd876e) 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) (959882a13e494bf916ba7f9174dd876e).
[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) (959882a13e494bf916ba7f9174dd876e) [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 959882a13e494bf916ba7f9174dd876e.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (15/16) (ce539819ee8a95997612d764291eb075) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (15/16) (ce539819ee8a95997612d764291eb075).
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) (ce539819ee8a95997612d764291eb075) [FINISHED]
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (4/16) (052149216554839dc996b623b64950c8) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (4/16) (052149216554839dc996b623b64950c8).
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16) (052149216554839dc996b623b64950c8) [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 ce539819ee8a95997612d764291eb075.
[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) (d91247b72e93218385d536a8bc3ba27e) 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 052149216554839dc996b623b64950c8.
[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) (959882a13e494bf916ba7f9174dd876e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (ce539819ee8a95997612d764291eb075) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (052149216554839dc996b623b64950c8) 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) (038335ff4c49964e8e84c544ab9e27c4) 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) (038335ff4c49964e8e84c544ab9e27c4).
[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) (038335ff4c49964e8e84c544ab9e27c4) [FINISHED]
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (11/16) (4a5304d3b05a868942fcb95c24c69582) 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/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 038335ff4c49964e8e84c544ab9e27c4.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (11/16) (4a5304d3b05a868942fcb95c24c69582).
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16) (4a5304d3b05a868942fcb95c24c69582) [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) (4b1f31c04e51769e38eafac06896b459) 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) (4b1f31c04e51769e38eafac06896b459).
[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) (4b1f31c04e51769e38eafac06896b459) [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 4a5304d3b05a868942fcb95c24c69582.
[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 4b1f31c04e51769e38eafac06896b459.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (14/16) (531ee8b1f4b85135b05847fd5b89d010) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (14/16) (531ee8b1f4b85135b05847fd5b89d010).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (531ee8b1f4b85135b05847fd5b89d010) [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 (11/16) (038335ff4c49964e8e84c544ab9e27c4) 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 ToKeyedWorkItem 531ee8b1f4b85135b05847fd5b89d010.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (4a5304d3b05a868942fcb95c24c69582) 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 (14/16) (4b1f31c04e51769e38eafac06896b459) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (531ee8b1f4b85135b05847fd5b89d010) 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) (5d8b4e1226d1aff3ddef5b51622c2afe) 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) (5d8b4e1226d1aff3ddef5b51622c2afe).
[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) (5d8b4e1226d1aff3ddef5b51622c2afe) [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/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 5d8b4e1226d1aff3ddef5b51622c2afe.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (23ecf8e299e080e251986269e98abe34) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (23ecf8e299e080e251986269e98abe34).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (23ecf8e299e080e251986269e98abe34) [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 ToKeyedWorkItem 23ecf8e299e080e251986269e98abe34.
[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 (2/16) (5d8b4e1226d1aff3ddef5b51622c2afe) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (23ecf8e299e080e251986269e98abe34) switched from RUNNING to FINISHED.
[grpc-default-executor-100] 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 (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) (cb1cf954dc801a9d06d8466baca5dc84) 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) (5693b78a2f95cdce0fa9784dbe101002) 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) (cb1cf954dc801a9d06d8466baca5dc84).
[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) (5693b78a2f95cdce0fa9784dbe101002).
[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) (cb1cf954dc801a9d06d8466baca5dc84) [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 cb1cf954dc801a9d06d8466baca5dc84.
[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) (35c68d68cca1d4d70d711f1734c443fa) 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) (35c68d68cca1d4d70d711f1734c443fa).
[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) (35c68d68cca1d4d70d711f1734c443fa) [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) (5693b78a2f95cdce0fa9784dbe101002) [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 5693b78a2f95cdce0fa9784dbe101002.
[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 35c68d68cca1d4d70d711f1734c443fa.
[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 (3/16) (cb1cf954dc801a9d06d8466baca5dc84) 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 - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (90ef93cc516adafed6b26e9d1ae3cc82) 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) (90ef93cc516adafed6b26e9d1ae3cc82).
[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) (90ef93cc516adafed6b26e9d1ae3cc82) [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 90ef93cc516adafed6b26e9d1ae3cc82.
[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) (5693b78a2f95cdce0fa9784dbe101002) 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) (35c68d68cca1d4d70d711f1734c443fa) 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) (90ef93cc516adafed6b26e9d1ae3cc82) 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 - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (0300e9e04b68750a30a072c83de366fc) 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) (0300e9e04b68750a30a072c83de366fc).
[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) (0300e9e04b68750a30a072c83de366fc) [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 0300e9e04b68750a30a072c83de366fc.
[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) (10e13530578c47051f9219c7315ff696) 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) (10e13530578c47051f9219c7315ff696).
[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) (10e13530578c47051f9219c7315ff696) [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 10e13530578c47051f9219c7315ff696.
[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 (5/16) (0300e9e04b68750a30a072c83de366fc) 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) (c03452ddc842ced74e05554525eac2b0) 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) (c03452ddc842ced74e05554525eac2b0).
[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) (c03452ddc842ced74e05554525eac2b0) [FINISHED]
[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) (b0c8375744c2618022448a029058f706) 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) (b0c8375744c2618022448a029058f706).
[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) (b0c8375744c2618022448a029058f706) [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 c03452ddc842ced74e05554525eac2b0.
[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) (10e13530578c47051f9219c7315ff696) 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 b0c8375744c2618022448a029058f706.
[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) (390f85f48ade7a9cdbca04680a7f00dc) 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) (390f85f48ade7a9cdbca04680a7f00dc).
[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) (acbb7b603bd5448b08bd8cbb0ac3cab4) 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 - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (390f85f48ade7a9cdbca04680a7f00dc) [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) (acbb7b603bd5448b08bd8cbb0ac3cab4).
[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 390f85f48ade7a9cdbca04680a7f00dc.
[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) (acbb7b603bd5448b08bd8cbb0ac3cab4) [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 acbb7b603bd5448b08bd8cbb0ac3cab4.
[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) (4cc8903ca3443fd40b79f4ef1bc4682e) 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) (4cc8903ca3443fd40b79f4ef1bc4682e).
[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 (9/16) (c03452ddc842ced74e05554525eac2b0) 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 - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (4cc8903ca3443fd40b79f4ef1bc4682e) [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 4cc8903ca3443fd40b79f4ef1bc4682e.
[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 (1/16) (b0c8375744c2618022448a029058f706) 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 (15/16) (390f85f48ade7a9cdbca04680a7f00dc) 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) (acbb7b603bd5448b08bd8cbb0ac3cab4) 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) (fc9ae20e9acb5e44e51e29eaa9df8520) 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) (fc9ae20e9acb5e44e51e29eaa9df8520).
[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) (5f7609ad4c7edec885cee3b380e6b647) 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) (5f7609ad4c7edec885cee3b380e6b647).
[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) (fc9ae20e9acb5e44e51e29eaa9df8520) [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) (5f7609ad4c7edec885cee3b380e6b647) [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 fc9ae20e9acb5e44e51e29eaa9df8520.
[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) (1ca3b8d7e289a7737ff9ab8caf960822) 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) (1ca3b8d7e289a7737ff9ab8caf960822).
[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) (8f9b4385ab8522dbc07c46ca406a3ce8) 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) (8f9b4385ab8522dbc07c46ca406a3ce8).
[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) (1ca3b8d7e289a7737ff9ab8caf960822) [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) (8f9b4385ab8522dbc07c46ca406a3ce8) [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 (14/16) (4cc8903ca3443fd40b79f4ef1bc4682e) 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 5f7609ad4c7edec885cee3b380e6b647.
[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 1ca3b8d7e289a7737ff9ab8caf960822.
[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 (16/16) (fc9ae20e9acb5e44e51e29eaa9df8520) 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 8f9b4385ab8522dbc07c46ca406a3ce8.
[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 (10/16) (5f7609ad4c7edec885cee3b380e6b647) 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 (11/16) (1ca3b8d7e289a7737ff9ab8caf960822) 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 (8/16) (8f9b4385ab8522dbc07c46ca406a3ce8) 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) (4ddbb238012ae2b9dc79a7677faa73c7) 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) (4ddbb238012ae2b9dc79a7677faa73c7).
[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) (4ddbb238012ae2b9dc79a7677faa73c7) [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 4ddbb238012ae2b9dc79a7677faa73c7.
[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) (4ddbb238012ae2b9dc79a7677faa73c7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1129020225-7a0e8962 (589b630e20bf2714411b72eb5c6aacc4) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 589b630e20bf2714411b72eb5c6aacc4.
[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 589b630e20bf2714411b72eb5c6aacc4 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-1129020225-7a0e8962(589b630e20bf2714411b72eb5c6aacc4).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 6fc4375c9c7dacb545c2eee5c322babe: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 589b630e20bf2714411b72eb5c6aacc4.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 8930db5514e1838e77ec6b547ccf4d5b@akka://flink/user/jobmanager_261 for job 589b630e20bf2714411b72eb5c6aacc4 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 589b630e20bf2714411b72eb5c6aacc4 with leader id 8930db5514e1838e77ec6b547ccf4d5b 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/dispatcherd5726d3a-74d7-4596-b80f-25feefb6c349.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherd5726d3a-74d7-4596-b80f-25feefb6c349.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-5] 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:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{fad20e29cd58992dd3dd74f65b28b9b4}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{b6c8d7c4a491c6ac0cf604b50e888e50}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{b0497205a47f85be4501be4205dce43d}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{86389fb05a2f8943e8ed462f67fa9f32}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{35cbaabd8fa3214f9e8e502d4de1a00b}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{56779ee057384adbeff6d5a4a19aa328}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{b10e49c0b6fa2deb717625846e838f47}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{625a10a56b66824e97b6933146589377}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{74a395ee10079586a103726b8568e562}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{631f781c22dde6707b3d0370d316ecf3}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{8e534e7670d4b694749d6e9e4ab31353}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{cf628808e93352165dce0dd15dd2f19b}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{298d1cdef6b9e34c780418819be44420}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[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{7c7d1002679e15ea4c9df997d372d1c5}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[flink-akka.actor.default-dispatcher-4] 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{c87384c787af5a439b8b6ddaa233aa26}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[flink-akka.actor.default-dispatcher-4] 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{0ba10e1846adb0faed7a1899f2fdf40b}, jobId: 589b630e20bf2714411b72eb5c6aacc4).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 589b630e20bf2714411b72eb5c6aacc4 from job leader monitoring.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 589b630e20bf2714411b72eb5c6aacc4.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 589b630e20bf2714411b72eb5c6aacc4.
[flink-akka.actor.default-dispatcher-4] 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.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[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/dispatcherd5726d3a-74d7-4596-b80f-25feefb6c349.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-3b845433-6ccd-469f-ab94-a555afcb6b90
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:37749
[flink-akka.actor.default-dispatcher-3] 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 6474 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@c5eedbbc
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1129020225-7a0e8962_a07133e1-6be8-4db6-889f-cf1806c7bf6c/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-1129020225-7a0e8962_a07133e1-6be8-4db6-889f-cf1806c7bf6c/
[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:42887
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:44379
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.504 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.947 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 11,5,main]) completed. Took 32 mins 2.413 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 24s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/vlmtsxaeu57ia
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