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: [email protected]
For additional commands, e-mail: [email protected]
