See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/50/display/redirect?page=changes>
Changes:
[ccy] Revert "Merge pull request #7051 from
------------------------------------------
[...truncated 229.08 MB...]
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (15/16) (bb90f54e212e8fbc43305ea92cda3145) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (15/16)
(bb90f54e212e8fbc43305ea92cda3145).
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16)
(bb90f54e212e8fbc43305ea92cda3145) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(8221a710b2da47f138d70f7f8da7d8cb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
4d682328b1c4bd065a4da9a25d0ddf26.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (e42e1ddd1ba3785020d2c7cb69e2adc0) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (9c74112c0de632fe28de3f07c30ebe05) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(9c74112c0de632fe28de3f07c30ebe05).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16)
(9c74112c0de632fe28de3f07c30ebe05) [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
bb90f54e212e8fbc43305ea92cda3145.
[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
(13/16) (5ec64054d188d8e7896022e7512a19cf) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
9c74112c0de632fe28de3f07c30ebe05.
[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) (26ce16a44f31856865aa5d7256bb725a) 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) (26ce16a44f31856865aa5d7256bb725a).
[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) (26ce16a44f31856865aa5d7256bb725a) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(15/16) (4d682328b1c4bd065a4da9a25d0ddf26) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
26ce16a44f31856865aa5d7256bb725a.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (bb90f54e212e8fbc43305ea92cda3145) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(6/16) (acd62360c0e835799ec650db7e7c5be0) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(6/16) (acd62360c0e835799ec650db7e7c5be0).
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (1/16) (59dac6dbb442ce9edd73ea2acc4c5dac) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (1/16)
(59dac6dbb442ce9edd73ea2acc4c5dac).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(6/16) (acd62360c0e835799ec650db7e7c5be0) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (9c74112c0de632fe28de3f07c30ebe05) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16)
(59dac6dbb442ce9edd73ea2acc4c5dac) [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
acd62360c0e835799ec650db7e7c5be0.
[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
59dac6dbb442ce9edd73ea2acc4c5dac.
[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
(1/16) (26ce16a44f31856865aa5d7256bb725a) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(3/16) (f7f2042d8cc3baa277e0690deeac8248) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(3/16) (f7f2042d8cc3baa277e0690deeac8248).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(3/16) (f7f2042d8cc3baa277e0690deeac8248) [FINISHED]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (6/16) (79a832bae4f7d755b3552b7651e8213c) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (6/16)
(79a832bae4f7d755b3552b7651e8213c).
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16)
(79a832bae4f7d755b3552b7651e8213c) [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
f7f2042d8cc3baa277e0690deeac8248.
[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
(6/16) (acd62360c0e835799ec650db7e7c5be0) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (3/16) (d13b51a51baa81a64f8ee41b86cc1c34) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (3/16)
(d13b51a51baa81a64f8ee41b86cc1c34).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16)
(59dac6dbb442ce9edd73ea2acc4c5dac) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
79a832bae4f7d755b3552b7651e8213c.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16)
(d13b51a51baa81a64f8ee41b86cc1c34) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(8/16) (1fcba77d701a470b1e588af20c33012f) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(8/16) (1fcba77d701a470b1e588af20c33012f).
[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
d13b51a51baa81a64f8ee41b86cc1c34.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(8/16) (1fcba77d701a470b1e588af20c33012f) [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
1fcba77d701a470b1e588af20c33012f.
[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
(3/16) (f7f2042d8cc3baa277e0690deeac8248) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(79a832bae4f7d755b3552b7651e8213c) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (e3dd1e3157949ca16356515efcfbcaf1) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (8/16)
(e3dd1e3157949ca16356515efcfbcaf1).
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16)
(e3dd1e3157949ca16356515efcfbcaf1) [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
e3dd1e3157949ca16356515efcfbcaf1.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16)
(d13b51a51baa81a64f8ee41b86cc1c34) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(8/16) (1fcba77d701a470b1e588af20c33012f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(e3dd1e3157949ca16356515efcfbcaf1) 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) (bdf8ff7bbb81e8a682d657adef2080d5) 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) (bdf8ff7bbb81e8a682d657adef2080d5).
[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) (bdf8ff7bbb81e8a682d657adef2080d5) [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
bdf8ff7bbb81e8a682d657adef2080d5.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (11/16) (cb72f95c2c4ae1957ec7a9025149c759) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (11/16)
(cb72f95c2c4ae1957ec7a9025149c759).
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16)
(cb72f95c2c4ae1957ec7a9025149c759) [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
cb72f95c2c4ae1957ec7a9025149c759.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(11/16) (bdf8ff7bbb81e8a682d657adef2080d5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (cb72f95c2c4ae1957ec7a9025149c759) 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) (4a811c92582ae33c2af3089fd1e6448a) 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) (4a811c92582ae33c2af3089fd1e6448a).
[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) (4a811c92582ae33c2af3089fd1e6448a) [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
4a811c92582ae33c2af3089fd1e6448a.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (a4a5e73f1f00130a39f9f8dfafbcb8c2) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(a4a5e73f1f00130a39f9f8dfafbcb8c2).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(a4a5e73f1f00130a39f9f8dfafbcb8c2) [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
a4a5e73f1f00130a39f9f8dfafbcb8c2.
[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) (4a811c92582ae33c2af3089fd1e6448a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(a4a5e73f1f00130a39f9f8dfafbcb8c2) switched from RUNNING to FINISHED.
[grpc-default-executor-184] 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)
(a36b858038d9fcca893e607ca766c52e) 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)
(a36b858038d9fcca893e607ca766c52e).
[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)
(a36b858038d9fcca893e607ca766c52e) [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
a36b858038d9fcca893e607ca766c52e.
[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)
(a36b858038d9fcca893e607ca766c52e) 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)
(f85b4bae92f7478c36b8827e3aaa33f7) 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)
(f85b4bae92f7478c36b8827e3aaa33f7).
[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)
(f85b4bae92f7478c36b8827e3aaa33f7) [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
f85b4bae92f7478c36b8827e3aaa33f7.
[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) (d54b6e8e96e5a44dfbdea374d2b09991) 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) (d54b6e8e96e5a44dfbdea374d2b09991).
[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 (6/16)
(f85b4bae92f7478c36b8827e3aaa33f7) 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 - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(16/16) (d54b6e8e96e5a44dfbdea374d2b09991) [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
d54b6e8e96e5a44dfbdea374d2b09991.
[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) (d54b6e8e96e5a44dfbdea374d2b09991) 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) (0fcd3ae3e0460d42858a2958bd5b71d2) 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) (0fcd3ae3e0460d42858a2958bd5b71d2).
[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)
(12a189b0f32f57b1377cb5f4e91d11d4) 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)
(12a189b0f32f57b1377cb5f4e91d11d4).
[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) (0fcd3ae3e0460d42858a2958bd5b71d2) [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)
(575f6928825f0fe659762f3d97dbd1c2) 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)
(575f6928825f0fe659762f3d97dbd1c2).
[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
0fcd3ae3e0460d42858a2958bd5b71d2.
[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)
(12a189b0f32f57b1377cb5f4e91d11d4) [FINISHED]
[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)
(575f6928825f0fe659762f3d97dbd1c2) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)
(0936223bff27c172cc57354a11091ed2) 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)
(0936223bff27c172cc57354a11091ed2).
[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)
(0936223bff27c172cc57354a11091ed2) [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
12a189b0f32f57b1377cb5f4e91d11d4.
[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) (aa17097992b885ed5e886e719c11a28f) 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) (aa17097992b885ed5e886e719c11a28f).
[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) (aa17097992b885ed5e886e719c11a28f) [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
575f6928825f0fe659762f3d97dbd1c2.
[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)
(994c1dfc317e2e473d48e72d9b73b1c0) 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)
(994c1dfc317e2e473d48e72d9b73b1c0).
[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) (1103631fa4b2e4e8e5f03c339653d7c3) 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) (1103631fa4b2e4e8e5f03c339653d7c3).
[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)
(994c1dfc317e2e473d48e72d9b73b1c0) [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) (1103631fa4b2e4e8e5f03c339653d7c3) [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
0936223bff27c172cc57354a11091ed2.
[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
aa17097992b885ed5e886e719c11a28f.
[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) (0a81b146a940b22eb1810a885d2dc0d8) 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) (0a81b146a940b22eb1810a885d2dc0d8).
[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) (0a81b146a940b22eb1810a885d2dc0d8) [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
994c1dfc317e2e473d48e72d9b73b1c0.
[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
1103631fa4b2e4e8e5f03c339653d7c3.
[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
0a81b146a940b22eb1810a885d2dc0d8.
[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) (0fcd3ae3e0460d42858a2958bd5b71d2) 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 (8/16)
(12a189b0f32f57b1377cb5f4e91d11d4) 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 (5/16)
(575f6928825f0fe659762f3d97dbd1c2) 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 (3/16)
(0936223bff27c172cc57354a11091ed2) 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) (aa17097992b885ed5e886e719c11a28f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)
(994c1dfc317e2e473d48e72d9b73b1c0) 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
(10/16) (1103631fa4b2e4e8e5f03c339653d7c3) 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
(14/16) (0a81b146a940b22eb1810a885d2dc0d8) 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)
(0e562ffc41b608145b28f344f0177f67) 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)
(7d143bf07f29a30e2c006324e6859da7) 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)
(0e562ffc41b608145b28f344f0177f67).
[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)
(7d143bf07f29a30e2c006324e6859da7).
[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)
(0e562ffc41b608145b28f344f0177f67) [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)
(7d143bf07f29a30e2c006324e6859da7) [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
0e562ffc41b608145b28f344f0177f67.
[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
7d143bf07f29a30e2c006324e6859da7.
[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) (ebea28fb015377e264a21b6f0d588b5e) 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) (ebea28fb015377e264a21b6f0d588b5e).
[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) (ebea28fb015377e264a21b6f0d588b5e) [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
ebea28fb015377e264a21b6f0d588b5e.
[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)
(0e562ffc41b608145b28f344f0177f67) 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 (7/16)
(7d143bf07f29a30e2c006324e6859da7) 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)
(17b2ae1b39cdebf3f0bdccbcdd3bbcb4) 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)
(17b2ae1b39cdebf3f0bdccbcdd3bbcb4).
[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)
(17b2ae1b39cdebf3f0bdccbcdd3bbcb4) [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) (3958116057ac43a3f01f825e14382466) 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) (3958116057ac43a3f01f825e14382466).
[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) (ebea28fb015377e264a21b6f0d588b5e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
17b2ae1b39cdebf3f0bdccbcdd3bbcb4.
[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) (3958116057ac43a3f01f825e14382466) [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
3958116057ac43a3f01f825e14382466.
[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)
(17b2ae1b39cdebf3f0bdccbcdd3bbcb4) 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) (3958116057ac43a3f01f825e14382466) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1129081645-a819d869
(1c5e8e6231bf419af5cd2245c443889b) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job 1c5e8e6231bf419af5cd2245c443889b.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
1c5e8e6231bf419af5cd2245c443889b reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1129081645-a819d869(1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 1c5e8e6231bf419af5cd2245c443889b.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
f032d7b6ff9915160d290026abf6c9e7: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager bf1373630c68e0968724a1f477174006@akka://flink/user/jobmanager_261
for job 1c5e8e6231bf419af5cd2245c443889b from the resource manager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
1c5e8e6231bf419af5cd2245c443889b with leader id
bf1373630c68e0968724a1f477174006 lost leadership.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher14733a07-88e5-4473-83cc-85db557648f2.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher14733a07-88e5-4473-83cc-85db557648f2.
[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-4] 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{e903e5710f40fdf761e7cb01f0721a3f}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{6d41a8d9b6487e2c7e66d549d5c7db70}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{06f7033b0ff66f249be3a3c074e00f75}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{b9ca3fcc13d57089d36bce50329e6b1f}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{da72760607406a523e7437f2db95b8fe}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{787c9cdd538a16451e413c4f43a8c4dd}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{5af8a5c928cbe124e86dfa4c68ce491f}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{d9fb7401f825e4ddca5970977421641f}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[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{79a9ad6b41b3a2dba345bf75a799879e}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{166eefe22e880a42e529732c3d277b44}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{12c79f906bb471c4828df96d07aefde9}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{98647d62f61de3ab7be51a38c98bc7fd}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] 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{a18972d35a539a822a7353c3bf5c5131}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[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-4] 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{7be9cdb84fceffe1ae183f785caa05a2}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher14733a07-88e5-4473-83cc-85db557648f2.
[flink-akka.actor.default-dispatcher-4] 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{1208d5e1d3505de991c5633bab340697}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[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{d57168a32ceffe9be8c494f2ecdced04}, jobId:
1c5e8e6231bf419af5cd2245c443889b).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
1c5e8e6231bf419af5cd2245c443889b from job leader monitoring.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 1c5e8e6231bf419af5cd2245c443889b.
[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-4] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-0049d3a5-c25c-45a7-afdd-4a11bbef1e42
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[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.
[ForkJoinPool.commonPool-worker-4] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-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:46645
[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 6388 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@379d4cc8
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1129081645-a819d869_183cd48d-0c2b-4f48-bc4c-e0f63674ede1/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-1129081645-a819d869_183cd48d-0c2b-4f48-bc4c-e0f63674ede1/
[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:38151
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:33991
Gradle Test Executor 2 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.58 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.949 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
> FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
(Thread[Task worker for ':' Thread 10,5,main]) completed. Took 33 mins 18.164
secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 36m 35s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/a757acml6qcpa
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]
