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 03:41:48 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming
#36
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/36/display/redirect?page=changes>
Changes:
[github] [BEAM-6102] Fix several packages that were being bundled without
------------------------------------------
[...truncated 228.66 MB...]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (5/16) (8f7e84a9e1ef5448609794bb3113910b).
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16) (8f7e84a9e1ef5448609794bb3113910b) [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) (42e457115b50651ee2e39152b4d35dbe) 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) (42e457115b50651ee2e39152b4d35dbe).
[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 8f7e84a9e1ef5448609794bb3113910b.
[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) (42e457115b50651ee2e39152b4d35dbe) [FINISHED]
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (13/16) (12b69cc4c02af51dacbc030ee7b0f7f3) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (13/16) (12b69cc4c02af51dacbc030ee7b0f7f3).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) (12b69cc4c02af51dacbc030ee7b0f7f3) [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 42e457115b50651ee2e39152b4d35dbe.
[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 (5/16) (0876a1c95404dd561eedeebe6abac460) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (8f7e84a9e1ef5448609794bb3113910b) 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 ToKeyedWorkItem 12b69cc4c02af51dacbc030ee7b0f7f3.
[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 (13/16) (42e457115b50651ee2e39152b4d35dbe) 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) (69f7816c4c7476c67c1926a55e16dc68) 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) (69f7816c4c7476c67c1926a55e16dc68).
[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) (69f7816c4c7476c67c1926a55e16dc68) [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 69f7816c4c7476c67c1926a55e16dc68.
[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) (dcfbf15e8fe3e3130aee90fa7cbfb736) 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) (dcfbf15e8fe3e3130aee90fa7cbfb736).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (12b69cc4c02af51dacbc030ee7b0f7f3) 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 - 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) (dcfbf15e8fe3e3130aee90fa7cbfb736) [FINISHED]
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (8a68440e4d1bfc1848581b7d09ce47f1) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (8a68440e4d1bfc1848581b7d09ce47f1).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (8a68440e4d1bfc1848581b7d09ce47f1) [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 dcfbf15e8fe3e3130aee90fa7cbfb736.
[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 8a68440e4d1bfc1848581b7d09ce47f1.
[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) (e6e05c805785c42289c06c01944a6f4a) 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) (e6e05c805785c42289c06c01944a6f4a).
[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) (e6e05c805785c42289c06c01944a6f4a) [FINISHED]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (6/16) (2d4f21c15cf3e4c2e0cc0f6e536bca25) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (6/16) (2d4f21c15cf3e4c2e0cc0f6e536bca25).
[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 e6e05c805785c42289c06c01944a6f4a.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) (2d4f21c15cf3e4c2e0cc0f6e536bca25) [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) (69f7816c4c7476c67c1926a55e16dc68) 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 2d4f21c15cf3e4c2e0cc0f6e536bca25.
[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 (6/16) (dcfbf15e8fe3e3130aee90fa7cbfb736) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (9/16) (4416f0dafb822e6aa0279e6e5b096e09) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (9/16) (4416f0dafb822e6aa0279e6e5b096e09).
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (4416f0dafb822e6aa0279e6e5b096e09) [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 4416f0dafb822e6aa0279e6e5b096e09.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (8a68440e4d1bfc1848581b7d09ce47f1) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16) (ded51737878c581b271270c86bf48acf) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/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 (8/16) (ded51737878c581b271270c86bf48acf).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.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/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16) (ded51737878c581b271270c86bf48acf) [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 ded51737878c581b271270c86bf48acf.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16) (8ad136222fd22d001c70a3513092cd79) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/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 (3/16) (8ad136222fd22d001c70a3513092cd79).
[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) (e6e05c805785c42289c06c01944a6f4a) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.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/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (3/16) (8ad136222fd22d001c70a3513092cd79) [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 8ad136222fd22d001c70a3513092cd79.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (2d4f21c15cf3e4c2e0cc0f6e536bca25) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (8/16) (3aa64a96db5150b58c1109b3ac431609) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (8/16) (3aa64a96db5150b58c1109b3ac431609).
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16) (3aa64a96db5150b58c1109b3ac431609) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (4416f0dafb822e6aa0279e6e5b096e09) 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 ToKeyedWorkItem 3aa64a96db5150b58c1109b3ac431609.
[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 (8/16) (ded51737878c581b271270c86bf48acf) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (3/16) (ea643d39c416162af5c24b28b5cda99e) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (3/16) (ea643d39c416162af5c24b28b5cda99e).
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16) (ea643d39c416162af5c24b28b5cda99e) [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 ea643d39c416162af5c24b28b5cda99e.
[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 (3/16) (8ad136222fd22d001c70a3513092cd79) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (3aa64a96db5150b58c1109b3ac431609) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (ea643d39c416162af5c24b28b5cda99e) 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) (21e2f74416be4983ef13af6fb4c7894a) 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) (21e2f74416be4983ef13af6fb4c7894a).
[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) (21e2f74416be4983ef13af6fb4c7894a) [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 21e2f74416be4983ef13af6fb4c7894a.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (9ed3949399d6ba23961c2a1bc4b689ac) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (9ed3949399d6ba23961c2a1bc4b689ac).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (9ed3949399d6ba23961c2a1bc4b689ac) [FINISHED]
[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 (2/16) (21e2f74416be4983ef13af6fb4c7894a) 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 9ed3949399d6ba23961c2a1bc4b689ac.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (9ed3949399d6ba23961c2a1bc4b689ac) switched from RUNNING to FINISHED.
[grpc-default-executor-122] 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 (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) (4230650fe4d08be9ae6fd38601a0d18f) 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) (4230650fe4d08be9ae6fd38601a0d18f).
[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) (4230650fe4d08be9ae6fd38601a0d18f) [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) (71fd19913cb75565a1e69f16ada4123e) 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) (f0ffd405acd462823d8373568c67aa0a) 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) (71fd19913cb75565a1e69f16ada4123e).
[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) (f0ffd405acd462823d8373568c67aa0a).
[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) (71fd19913cb75565a1e69f16ada4123e) [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) (f0ffd405acd462823d8373568c67aa0a) [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 4230650fe4d08be9ae6fd38601a0d18f.
[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) (0cdb754f49e4eff04607e6489eb4f72a) 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) (0cdb754f49e4eff04607e6489eb4f72a).
[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) (0cdb754f49e4eff04607e6489eb4f72a) [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 71fd19913cb75565a1e69f16ada4123e.
[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) (7b95ba90caa9f3f928c1cd7e4a1e5c6c) 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) (7b95ba90caa9f3f928c1cd7e4a1e5c6c).
[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 f0ffd405acd462823d8373568c67aa0a.
[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) (7b95ba90caa9f3f928c1cd7e4a1e5c6c) [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) (0300da91c2ccb81b478b59c558250f89) 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) (0300da91c2ccb81b478b59c558250f89).
[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 0cdb754f49e4eff04607e6489eb4f72a.
[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) (0300da91c2ccb81b478b59c558250f89) [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 7b95ba90caa9f3f928c1cd7e4a1e5c6c.
[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) (4230650fe4d08be9ae6fd38601a0d18f) 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) (d38a9a63907a3a55af00b4b966a0a1a6) 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) (d38a9a63907a3a55af00b4b966a0a1a6).
[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 0300da91c2ccb81b478b59c558250f89.
[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) (d38a9a63907a3a55af00b4b966a0a1a6) [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 d38a9a63907a3a55af00b4b966a0a1a6.
[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) (71fd19913cb75565a1e69f16ada4123e) 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) (378b40a4012a2044918f1ceedcc1ae3a) 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) (378b40a4012a2044918f1ceedcc1ae3a).
[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) (08424c801ed1fbeb1c4e61896072485b) 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) (08424c801ed1fbeb1c4e61896072485b).
[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) (378b40a4012a2044918f1ceedcc1ae3a) [FINISHED]
[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) (08424c801ed1fbeb1c4e61896072485b) [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 378b40a4012a2044918f1ceedcc1ae3a.
[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 08424c801ed1fbeb1c4e61896072485b.
[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) (f0ffd405acd462823d8373568c67aa0a) 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) (8f3ac3209eb0f13584a900f08abb011a) 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) (8f3ac3209eb0f13584a900f08abb011a).
[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) (0cdb754f49e4eff04607e6489eb4f72a) 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 - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (25364485de22d9cbb92f37f172da5837) 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 - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (8f3ac3209eb0f13584a900f08abb011a) [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) (25364485de22d9cbb92f37f172da5837).
[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) (25364485de22d9cbb92f37f172da5837) [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 8f3ac3209eb0f13584a900f08abb011a.
[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) (7b95ba90caa9f3f928c1cd7e4a1e5c6c) 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 25364485de22d9cbb92f37f172da5837.
[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 (1/16) (0300da91c2ccb81b478b59c558250f89) 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) (f3b0a8fb1ed174f363ed5da74e435e28) 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) (f3b0a8fb1ed174f363ed5da74e435e28).
[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) (f3b0a8fb1ed174f363ed5da74e435e28) [FINISHED]
[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) (7ffb5ede7164fa1ac9f1299a4daebf57) 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) (7ffb5ede7164fa1ac9f1299a4daebf57).
[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 f3b0a8fb1ed174f363ed5da74e435e28.
[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) (7ffb5ede7164fa1ac9f1299a4daebf57) [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 (10/16) (d38a9a63907a3a55af00b4b966a0a1a6) 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) (906b25ffe1842967eb87d654e6c790af) 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) (906b25ffe1842967eb87d654e6c790af).
[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) (2a2f4ba4f14966cf589ca3706c953653) 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) (2a2f4ba4f14966cf589ca3706c953653).
[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) (906b25ffe1842967eb87d654e6c790af) [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) (2a2f4ba4f14966cf589ca3706c953653) [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 7ffb5ede7164fa1ac9f1299a4daebf57.
[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) (378b40a4012a2044918f1ceedcc1ae3a) 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) (08424c801ed1fbeb1c4e61896072485b) 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 906b25ffe1842967eb87d654e6c790af.
[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) (8f3ac3209eb0f13584a900f08abb011a) 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 2a2f4ba4f14966cf589ca3706c953653.
[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) (25364485de22d9cbb92f37f172da5837) 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 (5/16) (f3b0a8fb1ed174f363ed5da74e435e28) 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) (7ffb5ede7164fa1ac9f1299a4daebf57) 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 (8/16) (906b25ffe1842967eb87d654e6c790af) 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) (2a2f4ba4f14966cf589ca3706c953653) 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) (6c1e7208d86b07ffb6487f3f1e2b476f) 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) (6c1e7208d86b07ffb6487f3f1e2b476f).
[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) (6c1e7208d86b07ffb6487f3f1e2b476f) [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 6c1e7208d86b07ffb6487f3f1e2b476f.
[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 (4/16) (6c1e7208d86b07ffb6487f3f1e2b476f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1128034127-f4fba3be (f507082dc61e35b208a910ba5c01c3af) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job f507082dc61e35b208a910ba5c01c3af.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job f507082dc61e35b208a910ba5c01c3af reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1128034127-f4fba3be(f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f507082dc61e35b208a910ba5c01c3af.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 1c68a9d1df29dcef5f643993de7b2242: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 9271ab024b7e2a347e5fa98ff4874412@akka://flink/user/jobmanager_261 for job f507082dc61e35b208a910ba5c01c3af from the resource manager.
[flink-akka.actor.default-dispatcher-6] 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-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher5949d42e-717e-48ae-ba34-7ed24fc4e175.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher5949d42e-717e-48ae-ba34-7ed24fc4e175.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job f507082dc61e35b208a910ba5c01c3af with leader id 9271ab024b7e2a347e5fa98ff4874412 lost leadership.
[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-5] 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{69d7bb6cfdfd086dab37df043617b447}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{ef167a8632a2678a05e0a8d8f29086e3}, jobId: f507082dc61e35b208a910ba5c01c3af).
[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{82b01017f76181d6361234854c21ef14}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{ba6e571031847229b9b514a6d3c41e4d}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{81e1bd659be29574bdd2c476dd98e609}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{962f28317440c67154437b75b9727a64}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{98a6d5a96ae10d2a9906eea26417fb9f}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{51b72d276c133b3f57efdc62237c7b0d}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{6fe8ee94ac1d229bc74d5b4984fcb28e}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{4b551e0a4a6dee045e8cb09ec6dba562}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{9b55b7c3251128b976ba28f6c8c4059a}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{5ea23ad8c921387a8abc1b7211cd8623}, jobId: f507082dc61e35b208a910ba5c01c3af).
[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{522d58c36383b8ea44ac5c1ec8f59abd}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{cb228ab322991ba93154d5a5754e8c4c}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{f920daacb67c3b79ef03f23398eb685c}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] 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{bfa817c79a04da592be04cf8a00b181b}, jobId: f507082dc61e35b208a910ba5c01c3af).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job f507082dc61e35b208a910ba5c01c3af from job leader monitoring.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job f507082dc61e35b208a910ba5c01c3af.
[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-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher5949d42e-717e-48ae-ba34-7ed24fc4e175.
[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-7fb40b54-029d-464f-a3db-e6506738c682
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[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.
[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-5] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:40633
[flink-akka.actor.default-dispatcher-5] 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 6360 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@f04c1259
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1128034127-f4fba3be_98782d15-f340-4fa4-94f3-72af47c15957/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-1128034127-f4fba3be_98782d15-f340-4fa4-94f3-72af47c15957/
[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:40639
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:37361
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.528 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.932 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 4,5,main]) completed. Took 32 mins 42.306 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 35m 7s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/izrvji53tea34
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