See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/17/display/redirect?page=changes>
Changes:
[coheigea] Switch to using java.nio.file.Files instead of Apache Commons IO
------------------------------------------
[...truncated 228.91 MB...]
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (ca748d1206844644ab74f2946323f33c) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(ca748d1206844644ab74f2946323f33c).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(ca748d1206844644ab74f2946323f33c) [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
ca748d1206844644ab74f2946323f33c.
[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
(2/16) (7ea7f9c991aeefdc4682e9bdc862e090) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(ca748d1206844644ab74f2946323f33c) switched from RUNNING to FINISHED.
[grpc-default-executor-166] WARN
org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not
supported in the current execution environment.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)
(6e01c80270c131a5147ee548b9d17e58) 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)
(6e01c80270c131a5147ee548b9d17e58).
[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)
(6e01c80270c131a5147ee548b9d17e58) [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
6e01c80270c131a5147ee548b9d17e58.
[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) (e3e2a2de7f64c0a93b83a13e0e59171c) 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) (e3e2a2de7f64c0a93b83a13e0e59171c).
[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) (e3e2a2de7f64c0a93b83a13e0e59171c) [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
e3e2a2de7f64c0a93b83a13e0e59171c.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)
(6e01c80270c131a5147ee548b9d17e58) 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
(16/16) (e3e2a2de7f64c0a93b83a13e0e59171c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)
(2a23edd2d0318b1f82515ad2522e9be5) 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)
(2a23edd2d0318b1f82515ad2522e9be5).
[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)
(2a23edd2d0318b1f82515ad2522e9be5) [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) (3dc0743fc6b81862dffcf7292fbcb6b4) 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) (3dc0743fc6b81862dffcf7292fbcb6b4).
[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)
(e399f91d5bb60ea8b374e5588b7a5ee8) 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)
(e399f91d5bb60ea8b374e5588b7a5ee8).
[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) (3dc0743fc6b81862dffcf7292fbcb6b4) [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)
(e399f91d5bb60ea8b374e5588b7a5ee8) [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
2a23edd2d0318b1f82515ad2522e9be5.
[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
3dc0743fc6b81862dffcf7292fbcb6b4.
[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
e399f91d5bb60ea8b374e5588b7a5ee8.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)
(2a23edd2d0318b1f82515ad2522e9be5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(10/16) (3dc0743fc6b81862dffcf7292fbcb6b4) 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) (f45eba78d3c38fb57742f801bbcc2245) 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) (f45eba78d3c38fb57742f801bbcc2245).
[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) (f45eba78d3c38fb57742f801bbcc2245) [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
f45eba78d3c38fb57742f801bbcc2245.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)
(e399f91d5bb60ea8b374e5588b7a5ee8) 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)
(f61e11fb0ef5bbc90f461c96e333333f) 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)
(f61e11fb0ef5bbc90f461c96e333333f).
[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)
(f61e11fb0ef5bbc90f461c96e333333f) [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
f61e11fb0ef5bbc90f461c96e333333f.
[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) (f45eba78d3c38fb57742f801bbcc2245) 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 (6/16)
(f61e11fb0ef5bbc90f461c96e333333f) 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)
(ac6d43eead4b4846861474be9848b85f) 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)
(ac6d43eead4b4846861474be9848b85f).
[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)
(ac6d43eead4b4846861474be9848b85f) [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
ac6d43eead4b4846861474be9848b85f.
[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)
(dabcb454d21884d6d6d1888db17b5116) 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)
(dabcb454d21884d6d6d1888db17b5116).
[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)
(dabcb454d21884d6d6d1888db17b5116) [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)
(3d7e623bdd8f2a0603f40f6c3401e222) 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)
(3d7e623bdd8f2a0603f40f6c3401e222).
[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)
(3d7e623bdd8f2a0603f40f6c3401e222) [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
dabcb454d21884d6d6d1888db17b5116.
[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
3d7e623bdd8f2a0603f40f6c3401e222.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)
(ac6d43eead4b4846861474be9848b85f) 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) (89811cf9cebd959f7da93b8a3c3cb088) 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) (89811cf9cebd959f7da93b8a3c3cb088).
[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) (89811cf9cebd959f7da93b8a3c3cb088) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)
(dabcb454d21884d6d6d1888db17b5116) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
89811cf9cebd959f7da93b8a3c3cb088.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)
(3d7e623bdd8f2a0603f40f6c3401e222) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(11/16) (89811cf9cebd959f7da93b8a3c3cb088) 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) (f0ef1eb2b7d0861e7f719edbc147e383) 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) (f0ef1eb2b7d0861e7f719edbc147e383).
[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) (f0ef1eb2b7d0861e7f719edbc147e383) [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
f0ef1eb2b7d0861e7f719edbc147e383.
[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
(12/16) (f0ef1eb2b7d0861e7f719edbc147e383) 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 -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(14/16) (8c186535a1e5ce5e7df1c9a6e0b9339e) 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) (8c186535a1e5ce5e7df1c9a6e0b9339e).
[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) (8c186535a1e5ce5e7df1c9a6e0b9339e) [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
8c186535a1e5ce5e7df1c9a6e0b9339e.
[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) (8c186535a1e5ce5e7df1c9a6e0b9339e) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(15/16) (fe97e5dbacf5685e6dcbad91fcc8fd52) 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) (fe97e5dbacf5685e6dcbad91fcc8fd52).
[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) (fe97e5dbacf5685e6dcbad91fcc8fd52) [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
fe97e5dbacf5685e6dcbad91fcc8fd52.
[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)
(43a3afb26cd61e388e8cd4c6297cc9b2) 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)
(43a3afb26cd61e388e8cd4c6297cc9b2).
[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)
(43a3afb26cd61e388e8cd4c6297cc9b2) [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
43a3afb26cd61e388e8cd4c6297cc9b2.
[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
(15/16) (fe97e5dbacf5685e6dcbad91fcc8fd52) 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)
(67437f4468ffa1cede4f2d2f90b01382) 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)
(67437f4468ffa1cede4f2d2f90b01382).
[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)
(67437f4468ffa1cede4f2d2f90b01382) [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
67437f4468ffa1cede4f2d2f90b01382.
[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 (7/16)
(43a3afb26cd61e388e8cd4c6297cc9b2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)
(67437f4468ffa1cede4f2d2f90b01382) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1126104624-96725a03
(a70d3b1301885eac76ed8ef83283b38c) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job a70d3b1301885eac76ed8ef83283b38c.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
a70d3b1301885eac76ed8ef83283b38c 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-1126104624-96725a03(a70d3b1301885eac76ed8ef83283b38c).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job a70d3b1301885eac76ed8ef83283b38c.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
f17445575ae7a6c061b8874223c38f21: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager 84022ef4b094ab1b0a033492bf5c4cbb@akka://flink/user/jobmanager_261
for job a70d3b1301885eac76ed8ef83283b38c from the resource manager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending 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-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher744e0815-d5ee-4292-a2f1-5b04f4a9ea3b.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher744e0815-d5ee-4292-a2f1-5b04f4a9ea3b.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
a70d3b1301885eac76ed8ef83283b38c with leader id
84022ef4b094ab1b0a033492bf5c4cbb lost leadership.
[flink-akka.actor.default-dispatcher-2] 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:7, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{f6ee8462c883915135c3d0b75afd2773}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{bd94ebb084278445eecc1fdada252277}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{7836bb88b26b6579652fee3175244b61}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{62b4cb79ea11732e27fa48d7a9aff4b5}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{7cd6f2bded6838fdc9e848799f90474d}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{fbd146d1c96430430c2b2a908d9e5769}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{cf6162aa7f768f483bb6541c429e5ae8}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{90a6c7d68678f162e6571746f1d53f03}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{e0053c5f6d421cccddebc7e495162a58}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{c57c58cd714dedc3af375bb568c71205}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{85572819d1fd1ae52bdcc5a44122b16b}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{4e555a63555588680f59b3b63c1ef988}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{c56b10c56fd56b408400ce2fd78c19d7}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{44527dc99979f22f2a13c5b5cc746c7d}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{79fbd82d40f87f28f1edf112380ba1db}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[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{c58f8efecb9fe82556e9afcca6734841}, jobId:
a70d3b1301885eac76ed8ef83283b38c).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
a70d3b1301885eac76ed8ef83283b38c from job leader monitoring.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job a70d3b1301885eac76ed8ef83283b38c.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-637ef36d-167a-40a9-ad8d-fe9ddbaa2ead
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-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/dispatcher744e0815-d5ee-4292-a2f1-5b04f4a9ea3b.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_260.
[FlinkCompletableFutureDelayScheduler-thread-1] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Could not properly
shut down Netty. Continue shut down of RestServerEndpoint.
[ForkJoinPool.commonPool-worker-13] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-13] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:40821
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 6494 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@eec7ac31
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1126104624-96725a03_3bf0ffe8-4d9b-4f5d-84ac-621a9005f4ed/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-1126104624-96725a03_3bf0ffe8-4d9b-4f5d-84ac-621a9005f4ed/
[grpc-default-executor-209] WARN
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client
failed unexpectedly.
[grpc-default-executor-166] ERROR
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Failed to handle for
unknown endpoint
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.StatusRuntimeException:
CANCELLED: cancelled before receiving half close
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Status.asRuntimeException(Status.java:517)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:272)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
[grpc-default-executor-209] WARN
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn
Logging client failed to be complete.
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.StatusRuntimeException:
CANCELLED: cancelled before receiving half close
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Status.asRuntimeException(Status.java:517)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:272)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Nov 26, 2018 10:46:42 AM
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor run
SEVERE: Exception while executing runnable
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed@54fb534d
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.StatusRuntimeException:
CANCELLED: call already cancelled
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.StatusRuntimeException:
CANCELLED: call already cancelled
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Status.asRuntimeException(Status.java:517)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
at
org.apache.beam.runners.fnexecution.state.GrpcStateService$Inbound.onError(GrpcStateService.java:145)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Status.asRuntimeException(Status.java:517)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
at
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.completeIfNotNull(GrpcLoggingService.java:78)
at
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.access$400(GrpcLoggingService.java:33)
at
org.apache.beam.runners.fnexecution.logging.GrpcLoggingService$InboundObserver.onError(GrpcLoggingService.java:105)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at
org.apache.beam.vendor.grpc.v1_13_1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
[pool-22633-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:44515
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:33875
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 3 failed, 2 skipped
Finished generating test XML results (0.798 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.969 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
> FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
(Thread[Task worker for ':' Thread 11,5,main]) completed. Took 37 mins 46.227
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 42m 18s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/2h3g3csfq7oj4
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]
