See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/18/display/redirect>
------------------------------------------
[...truncated 229.04 MB...]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (ba6d5829390d7b6e503c92806a30ca35) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (5/16)
(ba6d5829390d7b6e503c92806a30ca35).
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16)
(ba6d5829390d7b6e503c92806a30ca35) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(fe38fc4a37338ff3e80e4d7784bd944a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (863c1cd2ae3b2c695d0c79561aac7559) 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) (4a837976b184a4c9d6a6514f25838d3a) 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) (4a837976b184a4c9d6a6514f25838d3a).
[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) (4a837976b184a4c9d6a6514f25838d3a) [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
(6/16) (76f516df002ad6a64534398832720058) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (a77e55310878d87b2f862798e26f3ec0) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (16/16)
(a77e55310878d87b2f862798e26f3ec0).
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16)
(a77e55310878d87b2f862798e26f3ec0) [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) (9f48799267d9b18d69d7285c5bd777ed) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (11/16) (031c935ade51d6d0ecb1a6d39a65e39a) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (11/16)
(031c935ade51d6d0ecb1a6d39a65e39a).
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16)
(031c935ade51d6d0ecb1a6d39a65e39a) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
ffcde6cf3385182ed2a8c81699670057.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(10/16) (7bf557583676457156bca59415eceb9d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
3c0e8c7235bb852af9af04579c09e241.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
7349eb86799d79855d37518273711fca.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (741ca4ff0b0c1dbad17410e1620c2bb3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
ba6d5829390d7b6e503c92806a30ca35.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
4a837976b184a4c9d6a6514f25838d3a.
[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
(7/16) (146bac38169062eaf189f6f2bcc5c7e5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (78af29f4f22caf6dafe0f46bbce4cabb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
a77e55310878d87b2f862798e26f3ec0.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
031c935ade51d6d0ecb1a6d39a65e39a.
[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
(5/16) (ffcde6cf3385182ed2a8c81699670057) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(3c0e8c7235bb852af9af04579c09e241) 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
(16/16) (7349eb86799d79855d37518273711fca) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(ba6d5829390d7b6e503c92806a30ca35) switched from RUNNING to FINISHED.
[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
(11/16) (4a837976b184a4c9d6a6514f25838d3a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (a77e55310878d87b2f862798e26f3ec0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (031c935ade51d6d0ecb1a6d39a65e39a) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(8/16) (00201384330d0088d86f27c0bbdc84b5) 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) (00201384330d0088d86f27c0bbdc84b5).
[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) (00201384330d0088d86f27c0bbdc84b5) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
00201384330d0088d86f27c0bbdc84b5.
[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) (00201384330d0088d86f27c0bbdc84b5) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (68534f0b0439d560af24ae4903ced692) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (8/16)
(68534f0b0439d560af24ae4903ced692).
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16)
(68534f0b0439d560af24ae4903ced692) [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
68534f0b0439d560af24ae4903ced692.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(68534f0b0439d560af24ae4903ced692) 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 -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
(12/16) (76b29db19f59c693b29fdadbbe07bc27) 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) (76b29db19f59c693b29fdadbbe07bc27).
[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) (76b29db19f59c693b29fdadbbe07bc27) [FINISHED]
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (12/16) (403c765a9330d54a7fa725bc36967de0) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (12/16)
(403c765a9330d54a7fa725bc36967de0).
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16)
(403c765a9330d54a7fa725bc36967de0) [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/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
76b29db19f59c693b29fdadbbe07bc27.
[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 ToKeyedWorkItem
403c765a9330d54a7fa725bc36967de0.
[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) (8e6f8bf5ca48e24eb9d2808902523d33) 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) (8e6f8bf5ca48e24eb9d2808902523d33).
[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
(12/16) (76b29db19f59c693b29fdadbbe07bc27) 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 - 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) (8e6f8bf5ca48e24eb9d2808902523d33) [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/GatherAllOutputs/GroupByKey ->
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0
8e6f8bf5ca48e24eb9d2808902523d33.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (403c765a9330d54a7fa725bc36967de0) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (c097cca2a950911c0bec9730d4558b1a) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(c097cca2a950911c0bec9730d4558b1a).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16)
(c097cca2a950911c0bec9730d4558b1a) [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 ToKeyedWorkItem
c097cca2a950911c0bec9730d4558b1a.
[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
(13/16) (8e6f8bf5ca48e24eb9d2808902523d33) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (c097cca2a950911c0bec9730d4558b1a) 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) (2deca21065345675749102ab7d54fc19) 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) (2deca21065345675749102ab7d54fc19).
[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) (2deca21065345675749102ab7d54fc19) [FINISHED]
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (9a946628a5f66d741a6c3a93cdc8ea3e) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(9a946628a5f66d741a6c3a93cdc8ea3e).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(9a946628a5f66d741a6c3a93cdc8ea3e) [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
2deca21065345675749102ab7d54fc19.
[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
9a946628a5f66d741a6c3a93cdc8ea3e.
[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
(2/16) (2deca21065345675749102ab7d54fc19) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(9a946628a5f66d741a6c3a93cdc8ea3e) switched from RUNNING to FINISHED.
[grpc-default-executor-123] 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
(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) (33e3836019c448ebf90f69f81a9a228c) 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) (33e3836019c448ebf90f69f81a9a228c).
[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) (33e3836019c448ebf90f69f81a9a228c) [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
33e3836019c448ebf90f69f81a9a228c.
[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) (cb3b4bfa79148aaa4111f35b4e40df3c) 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) (cb3b4bfa79148aaa4111f35b4e40df3c).
[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) (cb3b4bfa79148aaa4111f35b4e40df3c) [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
cb3b4bfa79148aaa4111f35b4e40df3c.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(10/16) (33e3836019c448ebf90f69f81a9a228c) 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
(13/16) (cb3b4bfa79148aaa4111f35b4e40df3c) 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)
(e7af0360725ed751ea5f9dd989b1a900) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)
(1c3ca7649044f15e80bfa693eac0b7b9) 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)
(1c3ca7649044f15e80bfa693eac0b7b9).
[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)
(e7af0360725ed751ea5f9dd989b1a900).
[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)
(9feccb66b07811706608eff2a7dcd804) 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)
(9feccb66b07811706608eff2a7dcd804).
[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)
(1c3ca7649044f15e80bfa693eac0b7b9) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)
(e7af0360725ed751ea5f9dd989b1a900) [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)
(9feccb66b07811706608eff2a7dcd804) [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
1c3ca7649044f15e80bfa693eac0b7b9.
[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) (faae9c12993ba6d009ce7e35b3e64852) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
e7af0360725ed751ea5f9dd989b1a900.
[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) (faae9c12993ba6d009ce7e35b3e64852).
[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) (faae9c12993ba6d009ce7e35b3e64852) [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
9feccb66b07811706608eff2a7dcd804.
[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) (2028ccc714ee35097ba8a8b1f4fc5a3d) 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) (2028ccc714ee35097ba8a8b1f4fc5a3d).
[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) (2028ccc714ee35097ba8a8b1f4fc5a3d) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)
(1c3ca7649044f15e80bfa693eac0b7b9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
faae9c12993ba6d009ce7e35b3e64852.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)
(e7af0360725ed751ea5f9dd989b1a900) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
2028ccc714ee35097ba8a8b1f4fc5a3d.
[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) (6eda9421613cdbc24c6503c5379dae05) 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) (6eda9421613cdbc24c6503c5379dae05).
[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) (6eda9421613cdbc24c6503c5379dae05) [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
6eda9421613cdbc24c6503c5379dae05.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)
(9feccb66b07811706608eff2a7dcd804) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(16/16) (faae9c12993ba6d009ce7e35b3e64852) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(12/16) (2028ccc714ee35097ba8a8b1f4fc5a3d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(11/16) (6eda9421613cdbc24c6503c5379dae05) 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)
(3dd770092727a771ce1875670728d753) 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)
(3dd770092727a771ce1875670728d753).
[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)
(3dd770092727a771ce1875670728d753) [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
3dd770092727a771ce1875670728d753.
[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)
(3dd770092727a771ce1875670728d753) 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)
(8d412129681143260bdafd0b6c8bfafe) 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) (629a17201d7f257cf69c9b4d9b5e0741) 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)
(8d412129681143260bdafd0b6c8bfafe).
[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) (629a17201d7f257cf69c9b4d9b5e0741).
[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)
(8d412129681143260bdafd0b6c8bfafe) [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) (629a17201d7f257cf69c9b4d9b5e0741) [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
629a17201d7f257cf69c9b4d9b5e0741.
[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
8d412129681143260bdafd0b6c8bfafe.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
(14/16) (629a17201d7f257cf69c9b4d9b5e0741) 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 (9/16)
(8d412129681143260bdafd0b6c8bfafe) 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) (84d67f11eb7af9e9373ecaddfd5db20a) 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) (84d67f11eb7af9e9373ecaddfd5db20a).
[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) (84d67f11eb7af9e9373ecaddfd5db20a) [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
84d67f11eb7af9e9373ecaddfd5db20a.
[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)
(c3f899e48f16057bc9d71ade73f30d1d) 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)
(c3f899e48f16057bc9d71ade73f30d1d).
[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
(15/16) (84d67f11eb7af9e9373ecaddfd5db20a) 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)
(60b9c736f6c8557a5a505bca67d106f9) 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 - Ensuring all
FileSystem streams are closed for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)
(c3f899e48f16057bc9d71ade73f30d1d) [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)
(60b9c736f6c8557a5a505bca67d106f9).
[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)
(60b9c736f6c8557a5a505bca67d106f9) [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
c3f899e48f16057bc9d71ade73f30d1d.
[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
60b9c736f6c8557a5a505bca67d106f9.
[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)
(c3f899e48f16057bc9d71ade73f30d1d) 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 (8/16)
(60b9c736f6c8557a5a505bca67d106f9) 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 -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)
(9dc334c8e88580d1257d4f06fd6fa283) 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)
(9dc334c8e88580d1257d4f06fd6fa283).
[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)
(9dc334c8e88580d1257d4f06fd6fa283) [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
9dc334c8e88580d1257d4f06fd6fa283.
[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)
(01d4f68b98db4b70106c3a2173b9ffed) 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)
(01d4f68b98db4b70106c3a2173b9ffed).
[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)
(01d4f68b98db4b70106c3a2173b9ffed) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)
(9dc334c8e88580d1257d4f06fd6fa283) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0
01d4f68b98db4b70106c3a2173b9ffed.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)
(01d4f68b98db4b70106c3a2173b9ffed) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1126123649-632eca72
(dfa327508e2250e00e797d1596df5df2) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job dfa327508e2250e00e797d1596df5df2.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
dfa327508e2250e00e797d1596df5df2 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1126123649-632eca72(dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job dfa327508e2250e00e797d1596df5df2.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
350ceebdee1eea51990b06dc88c31505: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager a5048ff87057e9e8a91d8d8224f046b4@akka://flink/user/jobmanager_261
for job dfa327508e2250e00e797d1596df5df2 from the resource manager.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
dfa327508e2250e00e797d1596df5df2 with leader id
a5048ff87057e9e8a91d8d8224f046b4 lost leadership.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherc0d922ac-4cc5-4346-a1b9-c67e8fc6d040.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherc0d922ac-4cc5-4346-a1b9-c67e8fc6d040.
[flink-akka.actor.default-dispatcher-7] 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{f3fae3302bf9b90d80ce92b7531a469b}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-7] 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{4b55784a00da754642a8300eb617a45a}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] 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{52fa195974aa31454803d5f6476c2ad6}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherc0d922ac-4cc5-4346-a1b9-c67e8fc6d040.
[flink-akka.actor.default-dispatcher-7] 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{9346def27759f416873b2da9ea6e8024}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{ade70faece6a6ff05a5fb643a4eae8e1}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{7c5ca9a059610f1027e1150f94220abc}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{cf3c8b5e9499c0504f803ff5c7754b2a}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{a3d64e407d5cb0912fb913e6ae558a7b}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{029f364473866c498f9a09cf8b5ba392}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{300ff55012a35c67bd42fdf0aa26b07b}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{b86039085fa9c18094e614f6cad71d35}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{a2c7af6a4336fa68d47e1cb9c7b578c0}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{6f16a745d58a1d7f333bdddce4f33826}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{649e4547bdcdbe06ff5cdba21dcd782d}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{d802208233633a70f55cb0c2787ccf1c}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] 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{4a90b7e8063445b0da0c82433ceb0ea7}, jobId:
dfa327508e2250e00e797d1596df5df2).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
dfa327508e2250e00e797d1596df5df2 from job leader monitoring.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job dfa327508e2250e00e797d1596df5df2.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job dfa327508e2250e00e797d1596df5df2.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-e59b3de3-2a3c-49be-83ca-03fa2aeeea69
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[ForkJoinPool.commonPool-worker-2] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:43955
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 6806 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@e03100de
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1126123649-632eca72_9220cd9f-93f9-4f38-904d-cce474d7348a/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-1126123649-632eca72_9220cd9f-93f9-4f38-904d-cce474d7348a/
[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:37445
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:34839
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.769 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 (1.086 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 ':',5,main]) completed. Took 34 mins 38.724 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 59s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/bkqdueqrnybo2
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]
