See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/19/display/redirect?page=changes>
Changes:
[me] RedisIO: only call .exec on finishBundle if there is somthing to send
------------------------------------------
[...truncated 229.55 MB...]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(bdb730aa17b66dbff4ba7f386056d5aa).
[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/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
944c99466ed015aa00473c3db2205e65.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(bdb730aa17b66dbff4ba7f386056d5aa) [FINISHED]
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (9/16) (ddc9a74999f173eceb7eb5e56efbec42) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (9/16)
(ddc9a74999f173eceb7eb5e56efbec42).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(ad62dbe93b429d39269c3f02f12615c4) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16)
(ddc9a74999f173eceb7eb5e56efbec42) [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/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
8b8a1fe12934eb9e63b434038b4bdbfd.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(9/16) (944c99466ed015aa00473c3db2205e65) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
bdb730aa17b66dbff4ba7f386056d5aa.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
ddc9a74999f173eceb7eb5e56efbec42.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(10/16) (8b8a1fe12934eb9e63b434038b4bdbfd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (bdb730aa17b66dbff4ba7f386056d5aa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16)
(ddc9a74999f173eceb7eb5e56efbec42) 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) (e3158ddefca029a0f0225310b7d87815) 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) (e3158ddefca029a0f0225310b7d87815).
[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) (e3158ddefca029a0f0225310b7d87815) [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
e3158ddefca029a0f0225310b7d87815.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (11/16) (75689352f716728e300aa325a9a6fd31) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (11/16)
(75689352f716728e300aa325a9a6fd31).
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16)
(75689352f716728e300aa325a9a6fd31) [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
75689352f716728e300aa325a9a6fd31.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(12/16) (972e531cf141b52a4f0113ec047e11cf) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(12/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
(12/16) (972e531cf141b52a4f0113ec047e11cf).
[flink-akka.actor.default-dispatcher-2] 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) (e3158ddefca029a0f0225310b7d87815) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.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/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(12/16) (972e531cf141b52a4f0113ec047e11cf) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (75689352f716728e300aa325a9a6fd31) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(14/16) (83c8cc3a112e292179f8edc7ca34d9bb) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(14/16) (83c8cc3a112e292179f8edc7ca34d9bb).
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (12/16) (015755e1026d97932b9570fa5da157b8) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (12/16)
(015755e1026d97932b9570fa5da157b8).
[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
972e531cf141b52a4f0113ec047e11cf.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(14/16) (83c8cc3a112e292179f8edc7ca34d9bb) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(13/16) (752c32d989c0cd4a757c0d22c9e80e03) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(13/16) (752c32d989c0cd4a757c0d22c9e80e03).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(13/16) (752c32d989c0cd4a757c0d22c9e80e03) [FINISHED]
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16)
(015755e1026d97932b9570fa5da157b8) [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
83c8cc3a112e292179f8edc7ca34d9bb.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (14/16) (c6b5b69198ee8d8a5cb708083cc97056) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (14/16)
(c6b5b69198ee8d8a5cb708083cc97056).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16)
(c6b5b69198ee8d8a5cb708083cc97056) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(12/16) (972e531cf141b52a4f0113ec047e11cf) 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
752c32d989c0cd4a757c0d22c9e80e03.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (d4396a555c7d839ce5fb2bff6fd357d6) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(d4396a555c7d839ce5fb2bff6fd357d6).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16)
(d4396a555c7d839ce5fb2bff6fd357d6) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(14/16) (83c8cc3a112e292179f8edc7ca34d9bb) 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
015755e1026d97932b9570fa5da157b8.
[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
c6b5b69198ee8d8a5cb708083cc97056.
[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
d4396a555c7d839ce5fb2bff6fd357d6.
[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
(13/16) (752c32d989c0cd4a757c0d22c9e80e03) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(15/16) (5ae1b2c5f0ab666657a889ee4cf33cb5) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(15/16) (5ae1b2c5f0ab666657a889ee4cf33cb5).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(15/16) (5ae1b2c5f0ab666657a889ee4cf33cb5) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (015755e1026d97932b9570fa5da157b8) 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
5ae1b2c5f0ab666657a889ee4cf33cb5.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (c6b5b69198ee8d8a5cb708083cc97056) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (15/16) (58f12ce0ff662ad321f335e95e9366b7) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (15/16)
(58f12ce0ff662ad321f335e95e9366b7).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (d4396a555c7d839ce5fb2bff6fd357d6) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16)
(58f12ce0ff662ad321f335e95e9366b7) [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
58f12ce0ff662ad321f335e95e9366b7.
[flink-akka.actor.default-dispatcher-2] 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) (5ae1b2c5f0ab666657a889ee4cf33cb5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (58f12ce0ff662ad321f335e95e9366b7) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(16/16) (0b3516ea3021c7e1897cf7317d877be4) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(16/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
(16/16) (0b3516ea3021c7e1897cf7317d877be4).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.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/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(16/16) (0b3516ea3021c7e1897cf7317d877be4) [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) (d71256ae5ae38214a4af98bd1f32f888) 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) (d71256ae5ae38214a4af98bd1f32f888).
[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) (d71256ae5ae38214a4af98bd1f32f888) [FINISHED]
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (7897ff7917fdfc4519ec55f74adc55fa) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(7897ff7917fdfc4519ec55f74adc55fa).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(7897ff7917fdfc4519ec55f74adc55fa) [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/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
0b3516ea3021c7e1897cf7317d877be4.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (d276746c988cae01af21fffaad9075ab) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (16/16)
(d276746c988cae01af21fffaad9075ab).
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16)
(d276746c988cae01af21fffaad9075ab) [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/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
d71256ae5ae38214a4af98bd1f32f888.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
7897ff7917fdfc4519ec55f74adc55fa.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(16/16) (0b3516ea3021c7e1897cf7317d877be4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
d276746c988cae01af21fffaad9075ab.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(2/16) (d71256ae5ae38214a4af98bd1f32f888) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(7897ff7917fdfc4519ec55f74adc55fa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (d276746c988cae01af21fffaad9075ab) switched from RUNNING to FINISHED.
[pool-22514-thread-1] WARN
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown
endpoint.
[grpc-default-executor-44] 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)
(7929e3920bbc47fa096306ebf8574229) 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)
(7929e3920bbc47fa096306ebf8574229).
[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)
(7929e3920bbc47fa096306ebf8574229) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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
7929e3920bbc47fa096306ebf8574229.
[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)
(e891e61aa26528f2d0f384125bdbf37f) 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)
(e891e61aa26528f2d0f384125bdbf37f).
[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)
(e891e61aa26528f2d0f384125bdbf37f) [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
e891e61aa26528f2d0f384125bdbf37f.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)
(7929e3920bbc47fa096306ebf8574229) 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)
(e891e61aa26528f2d0f384125bdbf37f) 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) (db19e7ef4f5f6962367ae331b7cfda10) 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) (db19e7ef4f5f6962367ae331b7cfda10).
[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) (db19e7ef4f5f6962367ae331b7cfda10) [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
db19e7ef4f5f6962367ae331b7cfda10.
[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) (db19e7ef4f5f6962367ae331b7cfda10) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(16/16) (6c6a341a332a63e035e971710b71f6bc) 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) (6c6a341a332a63e035e971710b71f6bc).
[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) (6c6a341a332a63e035e971710b71f6bc) [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)
(58fd3896f0bddab2cebab9e726e09a02) 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)
(58fd3896f0bddab2cebab9e726e09a02).
[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)
(58fd3896f0bddab2cebab9e726e09a02) [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
6c6a341a332a63e035e971710b71f6bc.
[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)
(eef29e5fb0cb1ff996de0f154a7f3ef6) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)
(0fbea5a78cbe4e23e8f80a3603f90f49) 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)
(eef29e5fb0cb1ff996de0f154a7f3ef6).
[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)
(0fbea5a78cbe4e23e8f80a3603f90f49).
[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)
(eef29e5fb0cb1ff996de0f154a7f3ef6) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)
(0fbea5a78cbe4e23e8f80a3603f90f49) [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
58fd3896f0bddab2cebab9e726e09a02.
[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
eef29e5fb0cb1ff996de0f154a7f3ef6.
[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
0fbea5a78cbe4e23e8f80a3603f90f49.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(16/16) (6c6a341a332a63e035e971710b71f6bc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)
(58fd3896f0bddab2cebab9e726e09a02) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)
(eef29e5fb0cb1ff996de0f154a7f3ef6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)
(0fbea5a78cbe4e23e8f80a3603f90f49) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)
(5f38601c53c9103b07080073ae6fbae1) 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)
(5f38601c53c9103b07080073ae6fbae1).
[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)
(5f38601c53c9103b07080073ae6fbae1) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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
5f38601c53c9103b07080073ae6fbae1.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)
(5f38601c53c9103b07080073ae6fbae1) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)
(82a0ca2069a7783b014367c4862af60f) 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)
(82a0ca2069a7783b014367c4862af60f).
[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)
(82a0ca2069a7783b014367c4862af60f) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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
82a0ca2069a7783b014367c4862af60f.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)
(82a0ca2069a7783b014367c4862af60f) 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)
(1b3a21c8759c5531c1edf69ba0ad3f98) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(10/16) (74cb7d2bf83fd594811164843104deb0) 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)
(1b3a21c8759c5531c1edf69ba0ad3f98).
[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) (74cb7d2bf83fd594811164843104deb0).
[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)
(1b3a21c8759c5531c1edf69ba0ad3f98) [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) (74cb7d2bf83fd594811164843104deb0) [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
1b3a21c8759c5531c1edf69ba0ad3f98.
[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
74cb7d2bf83fd594811164843104deb0.
[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 (2/16)
(1b3a21c8759c5531c1edf69ba0ad3f98) switched from RUNNING to FINISHED.
[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
(10/16) (74cb7d2bf83fd594811164843104deb0) 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) (ef356089ec7a63d3d4971e6b7460f8b0) 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) (ef356089ec7a63d3d4971e6b7460f8b0).
[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) (8401d9543296f7adaeb011e6195120a8) 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) (8401d9543296f7adaeb011e6195120a8).
[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) (8401d9543296f7adaeb011e6195120a8) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(14/16) (ef356089ec7a63d3d4971e6b7460f8b0) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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
8401d9543296f7adaeb011e6195120a8.
[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) (0c71a3aa6ac160c7bd694ceee9dbb01d) 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) (0c71a3aa6ac160c7bd694ceee9dbb01d).
[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) (0c71a3aa6ac160c7bd694ceee9dbb01d) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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
ef356089ec7a63d3d4971e6b7460f8b0.
[flink-akka.actor.default-dispatcher-7] 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
0c71a3aa6ac160c7bd694ceee9dbb01d.
[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
(13/16) (8401d9543296f7adaeb011e6195120a8) 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) (fd336ffc90f7bb3b873813cdcc2bb620) 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) (fd336ffc90f7bb3b873813cdcc2bb620).
[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
(14/16) (ef356089ec7a63d3d4971e6b7460f8b0) 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 - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(11/16) (fd336ffc90f7bb3b873813cdcc2bb620) [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
fd336ffc90f7bb3b873813cdcc2bb620.
[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) (0c71a3aa6ac160c7bd694ceee9dbb01d) switched from RUNNING to FINISHED.
[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
(11/16) (fd336ffc90f7bb3b873813cdcc2bb620) 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)
(febd7f645c53a89571532cacbb7d911a) 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)
(febd7f645c53a89571532cacbb7d911a).
[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)
(febd7f645c53a89571532cacbb7d911a) [FINISHED]
[flink-akka.actor.default-dispatcher-7] 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
febd7f645c53a89571532cacbb7d911a.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)
(febd7f645c53a89571532cacbb7d911a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1126160155-c958470a
(9f4709e0c3a069ab312f9b1fa1f73519) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job 9f4709e0c3a069ab312f9b1fa1f73519.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
9f4709e0c3a069ab312f9b1fa1f73519 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1126160155-c958470a(9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 9f4709e0c3a069ab312f9b1fa1f73519.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
a5f970302aa799f5508701fff80b5ff5: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager a597d2d68aaf90311a6836eb13dd4cd7@akka://flink/user/jobmanager_261
for job 9f4709e0c3a069ab312f9b1fa1f73519 from the resource manager.
[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-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherde845384-98dc-4779-a103-afa05e4d1acb.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherde845384-98dc-4779-a103-afa05e4d1acb.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
9f4709e0c3a069ab312f9b1fa1f73519 with leader id
a597d2d68aaf90311a6836eb13dd4cd7 lost leadership.
[flink-akka.actor.default-dispatcher-3] 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{f15eeaaed9ea0aa15a9340fc1c2cee3f}, jobId:
9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] 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{134da7ef5ba8a3619eee20c1c71813f6}, jobId:
9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] 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{902015d581611d929511ed8c22882025}, jobId:
9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] 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{4eb27ba8f61842146d1ec3b4ccb3841f}, jobId:
9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] 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{8a67bbc72a36e0781d28618d1669be5b}, jobId:
9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] 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{1a7d8a654b883d670a87d0f3b0f9a28d}, jobId:
9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] 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{3137cf7144432256af038d38126ca0ba}, jobId:
9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] 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{f1195398f807b7249b814c1eac683b2b}, jobId:
9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] 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{2919200e03bfc32af8edba34af97dc7a}, jobId:
9f4709e0c3a069ab312f9b1fa1f73519).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherde845384-98dc-4779-a103-afa05e4d1acb.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-025634fe-b37e-446f-bb2f-24c52c2d0c8c
[flink-akka.actor.default-dispatcher-3] 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.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_260.
[ForkJoinPool.commonPool-worker-6] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:42097
[flink-akka.actor.default-dispatcher-6] 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 7628 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@8074a8a6
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1126160155-c958470a_9e42e763-837c-45f2-9a09-5bfc694d7e6f/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-1126160155-c958470a_9e42e763-837c-45f2-9a09-5bfc694d7e6f/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:45039
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:40511
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 (1.53 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.875 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 8,5,main]) completed. Took 32 mins 30.097
secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 35m 27s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/7vt63tjzyskyq
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]
