See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/141/display/redirect?page=changes>
Changes:
[robertwb] [BEAM-6120] Support retrieval of large gbk iterables over the state
API.
------------------------------------------
[...truncated 232.56 MB...]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)
(5560a8aa2245ffee17276a7abaa64a7d).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(a13890768fbd484604315804ef21ca11) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)
(5560a8aa2245ffee17276a7abaa64a7d) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
a13890768fbd484604315804ef21ca11.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
5560a8aa2245ffee17276a7abaa64a7d.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (14/16) (16180b0001e25929c8e4863921dbe5f7) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (11/16) (be9fbfe975c57fe8842afaaeda40dec6) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (11/16)
(be9fbfe975c57fe8842afaaeda40dec6).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (14/16)
(16180b0001e25929c8e4863921dbe5f7).
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16)
(be9fbfe975c57fe8842afaaeda40dec6) [FINISHED]
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16)
(16180b0001e25929c8e4863921dbe5f7) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
be9fbfe975c57fe8842afaaeda40dec6.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
16180b0001e25929c8e4863921dbe5f7.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(a13890768fbd484604315804ef21ca11) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)
(5560a8aa2245ffee17276a7abaa64a7d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (be9fbfe975c57fe8842afaaeda40dec6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (16180b0001e25929c8e4863921dbe5f7) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(553bfd2f9d5451c62ad9c616c164b02e) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(553bfd2f9d5451c62ad9c616c164b02e).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(553bfd2f9d5451c62ad9c616c164b02e) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(4085bd21c0a1226b1714f377a0722a6c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(5e8615f2ab55d47461069e5c303529f0) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(4085bd21c0a1226b1714f377a0722a6c).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(5e8615f2ab55d47461069e5c303529f0).
[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 ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
553bfd2f9d5451c62ad9c616c164b02e.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(4085bd21c0a1226b1714f377a0722a6c) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(5e8615f2ab55d47461069e5c303529f0) [FINISHED]
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (7/16) (d6e911201196a8b94c50e77e176722c9) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (7/16)
(d6e911201196a8b94c50e77e176722c9).
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (62c49dcf018c9d6e2d946c7c5fc908e4) switched from RUNNING
to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(67e02fde5e28ea5045fab21eb6f18b07) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (5/16)
(62c49dcf018c9d6e2d946c7c5fc908e4).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(67e02fde5e28ea5045fab21eb6f18b07).
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (af848bfd889d2ae34676079572d9482a) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (8/16)
(af848bfd889d2ae34676079572d9482a).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)
(b1a773713af8a8d743a842e2fa21e87e) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)
(b1a773713af8a8d743a842e2fa21e87e).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16)
(d6e911201196a8b94c50e77e176722c9) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)
(b1a773713af8a8d743a842e2fa21e87e) [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 ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
4085bd21c0a1226b1714f377a0722a6c.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16)
(af848bfd889d2ae34676079572d9482a) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(67e02fde5e28ea5045fab21eb6f18b07) [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 ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
5e8615f2ab55d47461069e5c303529f0.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16)
(62c49dcf018c9d6e2d946c7c5fc908e4) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(553bfd2f9d5451c62ad9c616c164b02e) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(d33a97381973e03545a85932a2b31e15) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(d33a97381973e03545a85932a2b31e15).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(d33a97381973e03545a85932a2b31e15) [FINISHED]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (5bfc2cd018c31184800f79fdffa8f058) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(5bfc2cd018c31184800f79fdffa8f058).
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(5bfc2cd018c31184800f79fdffa8f058) [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
d6e911201196a8b94c50e77e176722c9.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (1/16) (b05d9c5ef73f8722695eeb2aebed5218) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (1/16)
(b05d9c5ef73f8722695eeb2aebed5218).
[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 ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
b1a773713af8a8d743a842e2fa21e87e.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16)
(b05d9c5ef73f8722695eeb2aebed5218) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(4085bd21c0a1226b1714f377a0722a6c) switched from RUNNING to 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
af848bfd889d2ae34676079572d9482a.
[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 ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
67e02fde5e28ea5045fab21eb6f18b07.
[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
62c49dcf018c9d6e2d946c7c5fc908e4.
[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 ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
d33a97381973e03545a85932a2b31e15.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (22992a82c989e947d4323bd0cfdadbe9) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(22992a82c989e947d4323bd0cfdadbe9).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16)
(22992a82c989e947d4323bd0cfdadbe9) [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
5bfc2cd018c31184800f79fdffa8f058.
[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
b05d9c5ef73f8722695eeb2aebed5218.
[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
22992a82c989e947d4323bd0cfdadbe9.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(5e8615f2ab55d47461069e5c303529f0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(d6e911201196a8b94c50e77e176722c9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)
(b1a773713af8a8d743a842e2fa21e87e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(af848bfd889d2ae34676079572d9482a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(67e02fde5e28ea5045fab21eb6f18b07) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(62c49dcf018c9d6e2d946c7c5fc908e4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(d33a97381973e03545a85932a2b31e15) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (5bfc2cd018c31184800f79fdffa8f058) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16)
(b05d9c5ef73f8722695eeb2aebed5218) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (22992a82c989e947d4323bd0cfdadbe9) switched from RUNNING to FINISHED.
[grpc-default-executor-131] WARN
org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not
supported in the current execution environment.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(6f02d9ad5856823d53d45ae533f9dfe6) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(6f02d9ad5856823d53d45ae533f9dfe6).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(6f02d9ad5856823d53d45ae533f9dfe6) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
6f02d9ad5856823d53d45ae533f9dfe6.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (39081291c1a90eb163da323aac7751ab) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(39081291c1a90eb163da323aac7751ab).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(39081291c1a90eb163da323aac7751ab) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
39081291c1a90eb163da323aac7751ab.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(6f02d9ad5856823d53d45ae533f9dfe6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(39081291c1a90eb163da323aac7751ab) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(04541f9b55915273bf693130537b4b9e) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(8ec390f493de10dd463185c526dbbc98) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(04541f9b55915273bf693130537b4b9e).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(8ec390f493de10dd463185c526dbbc98).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(8ec390f493de10dd463185c526dbbc98) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(04541f9b55915273bf693130537b4b9e) [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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
04541f9b55915273bf693130537b4b9e.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(e9ed4492e897f5325adbc5df715dca22) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(e9ed4492e897f5325adbc5df715dca22).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(e9ed4492e897f5325adbc5df715dca22) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(be731a2b7b9e1ac3276fecf00c5d0d52) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(be731a2b7b9e1ac3276fecf00c5d0d52).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(be731a2b7b9e1ac3276fecf00c5d0d52) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(9618fd324e26b79ec41d104901bf065f) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(9618fd324e26b79ec41d104901bf065f).
[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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
8ec390f493de10dd463185c526dbbc98.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(9618fd324e26b79ec41d104901bf065f) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(892c1f28935fbd7439be814720132d8f) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(892c1f28935fbd7439be814720132d8f).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(892c1f28935fbd7439be814720132d8f) [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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
e9ed4492e897f5325adbc5df715dca22.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(4a1f607009b556070f82c8eb170659a3) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(4a1f607009b556070f82c8eb170659a3).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(4a1f607009b556070f82c8eb170659a3) [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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
be731a2b7b9e1ac3276fecf00c5d0d52.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(04541f9b55915273bf693130537b4b9e) switched from RUNNING to 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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
9618fd324e26b79ec41d104901bf065f.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(0ae9f9d9366601d4ea0ed1ee0f1da965) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(0ae9f9d9366601d4ea0ed1ee0f1da965).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(0ae9f9d9366601d4ea0ed1ee0f1da965) [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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
892c1f28935fbd7439be814720132d8f.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(8ec390f493de10dd463185c526dbbc98) switched from RUNNING to 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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
4a1f607009b556070f82c8eb170659a3.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(e9ed4492e897f5325adbc5df715dca22) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(f3f2400452335b8fb47ab4f6027075cb) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(f3f2400452335b8fb47ab4f6027075cb).
[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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
0ae9f9d9366601d4ea0ed1ee0f1da965.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(f3f2400452335b8fb47ab4f6027075cb) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(be731a2b7b9e1ac3276fecf00c5d0d52) switched from RUNNING to 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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
f3f2400452335b8fb47ab4f6027075cb.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(868fa9304995122ed308114a7e36dddc) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(868fa9304995122ed308114a7e36dddc).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(868fa9304995122ed308114a7e36dddc) [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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
868fa9304995122ed308114a7e36dddc.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(9618fd324e26b79ec41d104901bf065f) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(ecb1f0c2352e7ff38017264203f9264c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(5b84946682596001552b8985c6171059) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(ecb1f0c2352e7ff38017264203f9264c).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(5b84946682596001552b8985c6171059).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(ecb1f0c2352e7ff38017264203f9264c) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(5b84946682596001552b8985c6171059) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
ecb1f0c2352e7ff38017264203f9264c.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(892c1f28935fbd7439be814720132d8f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(4a1f607009b556070f82c8eb170659a3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
5b84946682596001552b8985c6171059.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(0ae9f9d9366601d4ea0ed1ee0f1da965) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(f3f2400452335b8fb47ab4f6027075cb) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(52c0656512ad018d38dd4e43e7c7ae2a) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(52c0656512ad018d38dd4e43e7c7ae2a).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(52c0656512ad018d38dd4e43e7c7ae2a) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(868fa9304995122ed308114a7e36dddc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
52c0656512ad018d38dd4e43e7c7ae2a.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(ecb1f0c2352e7ff38017264203f9264c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(385d6ea32af17331da8197aa163149d9) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(385d6ea32af17331da8197aa163149d9).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(385d6ea32af17331da8197aa163149d9) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(5538eed5f7a0caa5946e916496e39070) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(5538eed5f7a0caa5946e916496e39070).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(5538eed5f7a0caa5946e916496e39070) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
385d6ea32af17331da8197aa163149d9.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(5b84946682596001552b8985c6171059) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(52c0656512ad018d38dd4e43e7c7ae2a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
5538eed5f7a0caa5946e916496e39070.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(385d6ea32af17331da8197aa163149d9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(5538eed5f7a0caa5946e916496e39070) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(023ec7f024283a2cf258750f561f67fc) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(023ec7f024283a2cf258750f561f67fc).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(023ec7f024283a2cf258750f561f67fc) [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 ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
023ec7f024283a2cf258750f561f67fc.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(023ec7f024283a2cf258750f561f67fc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1210121742-dbcbe40c
(d59aa3791b0748c193e7559c2267953c) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job d59aa3791b0748c193e7559c2267953c.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
d59aa3791b0748c193e7559c2267953c reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1210121742-dbcbe40c(d59aa3791b0748c193e7559c2267953c).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job d59aa3791b0748c193e7559c2267953c.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
f878b51eae734f0090af0dadf8e82be6: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher7789b5e1-1b29-4ab3-917c-122e2ecf9353.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher7789b5e1-1b29-4ab3-917c-122e2ecf9353.
[flink-akka.actor.default-dispatcher-2] 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{81f385878f80a28c39f77578c1dc4460}, jobId:
d59aa3791b0748c193e7559c2267953c).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
d59aa3791b0748c193e7559c2267953c with leader id
a57625dc03434ff1848a2256d64c4b7b lost leadership.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager a57625dc03434ff1848a2256d64c4b7b@akka://flink/user/jobmanager_261
for job d59aa3791b0748c193e7559c2267953c from the resource manager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-2] 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{cd12453aa3bc9c44266ad6092aa0e022}, jobId:
d59aa3791b0748c193e7559c2267953c).
[flink-akka.actor.default-dispatcher-2] 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{73b7a2289099430693140fcf5e67b821}, jobId:
d59aa3791b0748c193e7559c2267953c).
[flink-akka.actor.default-dispatcher-2] 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{32485f856cb51aa002a8c216164be7f4}, jobId:
d59aa3791b0748c193e7559c2267953c).
[flink-akka.actor.default-dispatcher-2] 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{91916f83156452f475802e7f65d030f1}, jobId:
d59aa3791b0748c193e7559c2267953c).
[flink-akka.actor.default-dispatcher-2] 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{2c2f0b6c9e8bd02a4ca53a5050a80e12}, jobId:
d59aa3791b0748c193e7559c2267953c).
[flink-akka.actor.default-dispatcher-2] 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{9e62be369b63722a4ef4ffc064e4309c}, jobId:
d59aa3791b0748c193e7559c2267953c).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-c006b8c9-f9cc-4fc2-b7c8-84842b53025c
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[ForkJoinPool.commonPool-worker-6] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[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/dispatcher7789b5e1-1b29-4ab3-917c-122e2ecf9353.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-2] 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:42703
[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 9956 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@ef12ef13
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1210121742-dbcbe40c_afac09d8-9940-4be3-8eb3-87d2ae78f0c6/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-1210121742-dbcbe40c_afac09d8-9940-4be3-8eb3-87d2ae78f0c6/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:36713
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:40069
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.468 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.98 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
> FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
(Thread[Task worker for ':' Thread 11,5,main]) completed. Took 41 mins 52.206
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 45m 30s
75 actionable tasks: 74 executed, 1 up-to-date
Publishing build scan...
https://gradle.com/s/hhf5dknbt7dt6
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]
