See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/209/display/redirect?page=changes>
Changes:
[robertwb] More robust FnApi Runner.
------------------------------------------
[...truncated 232.47 MB...]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(15f205d2bf876dad988d620fbc2105ce) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(15f205d2bf876dad988d620fbc2105ce).
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (9/16) (a300f86d47c3f0026bd7b3d2b28b38db) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (9/16)
(a300f86d47c3f0026bd7b3d2b28b38db).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(15f205d2bf876dad988d620fbc2105ce) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(22b2aa96355ebe4d11a76cbec5cadaf0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (2e5675df16e82a0977ef3acb60b5fccf) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
f4551759bc9b1fd8517fc98cbe375ce0.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(22b2aa96355ebe4d11a76cbec5cadaf0).
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16)
(a300f86d47c3f0026bd7b3d2b28b38db) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(22b2aa96355ebe4d11a76cbec5cadaf0) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(422f149f35f544897524dcfed4c7008a) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(422f149f35f544897524dcfed4c7008a).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16)
(e53746a7b21dc64ae5c07af792633a99) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(422f149f35f544897524dcfed4c7008a) [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
2ee0f557c6fdba88bf4207addd40a52c.
[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
a60c1cc0b8329345b98b2e0de24d062d.
[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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
15f205d2bf876dad988d620fbc2105ce.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(53a3386a0399b646e32747277468b8f4) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (9863532710ae337dc027e792cecb352d) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (8/16)
(9863532710ae337dc027e792cecb352d).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(8e989bc878a8e6f270b49962947debcc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
a300f86d47c3f0026bd7b3d2b28b38db.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16)
(9863532710ae337dc027e792cecb352d) [FINISHED]
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (e0e88d9902eb4ebb3b5e5d5c0b812a82) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(e0e88d9902eb4ebb3b5e5d5c0b812a82).
[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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
22b2aa96355ebe4d11a76cbec5cadaf0.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(366d5a168da1054d9be9dcdfe7c08e31) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(366d5a168da1054d9be9dcdfe7c08e31).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (9393e3f1da2124ef4f14844556ac0b4b) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16)
(e0e88d9902eb4ebb3b5e5d5c0b812a82) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(366d5a168da1054d9be9dcdfe7c08e31) [FINISHED]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (a07282b558c6fcd89047d5e5ebae4646) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(a07282b558c6fcd89047d5e5ebae4646).
[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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
422f149f35f544897524dcfed4c7008a.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(a07282b558c6fcd89047d5e5ebae4646) [FINISHED]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (7b04041fed2adeffe02bacc8d79a461a) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (5/16)
(7b04041fed2adeffe02bacc8d79a461a).
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16)
(7b04041fed2adeffe02bacc8d79a461a) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)
(aed8a4e4850c65066340fd60fe592f09) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
9863532710ae337dc027e792cecb352d.
[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
e0e88d9902eb4ebb3b5e5d5c0b812a82.
[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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
366d5a168da1054d9be9dcdfe7c08e31.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(9c2de696b32e80f089c75eeb17906c61) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
a07282b558c6fcd89047d5e5ebae4646.
[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
7b04041fed2adeffe02bacc8d79a461a.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (3/16) (66287ac19f115aa9b1c281661cc37964) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (3/16)
(66287ac19f115aa9b1c281661cc37964).
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16)
(66287ac19f115aa9b1c281661cc37964) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)
(dce2cd1e55f43cb875f19676748db1ed) switched from RUNNING to 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 ToKeyedWorkItem
66287ac19f115aa9b1c281661cc37964.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (9bea92a0048ae2efc069deda4e60e7b1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)
(b6dd94f995b1deb03b13d9f8193e9da8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(f4551759bc9b1fd8517fc98cbe375ce0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16)
(2ee0f557c6fdba88bf4207addd40a52c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (a60c1cc0b8329345b98b2e0de24d062d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(15f205d2bf876dad988d620fbc2105ce) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16)
(a300f86d47c3f0026bd7b3d2b28b38db) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(22b2aa96355ebe4d11a76cbec5cadaf0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(422f149f35f544897524dcfed4c7008a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(9863532710ae337dc027e792cecb352d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (e0e88d9902eb4ebb3b5e5d5c0b812a82) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(366d5a168da1054d9be9dcdfe7c08e31) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (a07282b558c6fcd89047d5e5ebae4646) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(7b04041fed2adeffe02bacc8d79a461a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16)
(66287ac19f115aa9b1c281661cc37964) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(22a6a56ac549408ff04f0555de422898) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(22a6a56ac549408ff04f0555de422898).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(22a6a56ac549408ff04f0555de422898) [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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
22a6a56ac549408ff04f0555de422898.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (58523ad39fd006d371f4fb0af028739a) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(58523ad39fd006d371f4fb0af028739a).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(58523ad39fd006d371f4fb0af028739a) [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 ToKeyedWorkItem
58523ad39fd006d371f4fb0af028739a.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(22a6a56ac549408ff04f0555de422898) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(58523ad39fd006d371f4fb0af028739a) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(edadd3d4046a3ab9710fc8599cab9b77) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(6872c5600e9f9ae2f77047c627e6a7c6) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(edadd3d4046a3ab9710fc8599cab9b77).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(c351d19a2d0b47921a2806291565c49c) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(6872c5600e9f9ae2f77047c627e6a7c6).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(c351d19a2d0b47921a2806291565c49c).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(edadd3d4046a3ab9710fc8599cab9b77) [FINISHED]
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(6872c5600e9f9ae2f77047c627e6a7c6) [FINISHED]
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(c351d19a2d0b47921a2806291565c49c) [FINISHED]
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(30c15914dc011299e8993d6a4751b5eb) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(30c15914dc011299e8993d6a4751b5eb).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(4cbc61726d371633473a483884db1857) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(8956c9f9c9244efaf4e22ee4105020cc) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(4cbc61726d371633473a483884db1857).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(8956c9f9c9244efaf4e22ee4105020cc).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(30c15914dc011299e8993d6a4751b5eb) [FINISHED]
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(4cbc61726d371633473a483884db1857) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
edadd3d4046a3ab9710fc8599cab9b77.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(8956c9f9c9244efaf4e22ee4105020cc) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
6872c5600e9f9ae2f77047c627e6a7c6.
[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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
c351d19a2d0b47921a2806291565c49c.
[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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
4cbc61726d371633473a483884db1857.
[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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
30c15914dc011299e8993d6a4751b5eb.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(edadd3d4046a3ab9710fc8599cab9b77) 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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
8956c9f9c9244efaf4e22ee4105020cc.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(6872c5600e9f9ae2f77047c627e6a7c6) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(68ff0e8796869c3f8a42be00a10f28e1) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(68ff0e8796869c3f8a42be00a10f28e1).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(68ff0e8796869c3f8a42be00a10f28e1) [FINISHED]
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(677f76a6f0826ef074ce210e97d32d25) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(677f76a6f0826ef074ce210e97d32d25).
[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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
68ff0e8796869c3f8a42be00a10f28e1.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(677f76a6f0826ef074ce210e97d32d25) [FINISHED]
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(d505ae6d2e18c2d10a965d4659c2d93a) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(d505ae6d2e18c2d10a965d4659c2d93a).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(c351d19a2d0b47921a2806291565c49c) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(d505ae6d2e18c2d10a965d4659c2d93a) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
677f76a6f0826ef074ce210e97d32d25.
[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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
d505ae6d2e18c2d10a965d4659c2d93a.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(4cbc61726d371633473a483884db1857) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(30c15914dc011299e8993d6a4751b5eb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(8956c9f9c9244efaf4e22ee4105020cc) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(cc106d958afb2d4e7048e33a2129d5fa) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(cc106d958afb2d4e7048e33a2129d5fa).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(cc106d958afb2d4e7048e33a2129d5fa) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
cc106d958afb2d4e7048e33a2129d5fa.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(b30262824aa06d12708b42bee31d8d25) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(b30262824aa06d12708b42bee31d8d25).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(68ff0e8796869c3f8a42be00a10f28e1) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(b30262824aa06d12708b42bee31d8d25) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
b30262824aa06d12708b42bee31d8d25.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(677f76a6f0826ef074ce210e97d32d25) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(f185d21eb6d6830b9a87f64c7f2559c7) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(f185d21eb6d6830b9a87f64c7f2559c7).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(f185d21eb6d6830b9a87f64c7f2559c7) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(d505ae6d2e18c2d10a965d4659c2d93a) switched from RUNNING to 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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
f185d21eb6d6830b9a87f64c7f2559c7.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(cc106d958afb2d4e7048e33a2129d5fa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(b30262824aa06d12708b42bee31d8d25) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(c7ac969b0260d6e873a4f9338af4787d) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(c7ac969b0260d6e873a4f9338af4787d).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(9f5ad1a930c224922df1baad44b426b8) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(c7ac969b0260d6e873a4f9338af4787d) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(f185d21eb6d6830b9a87f64c7f2559c7) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(9f5ad1a930c224922df1baad44b426b8).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(9f5ad1a930c224922df1baad44b426b8) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
c7ac969b0260d6e873a4f9338af4787d.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(7b2235f48914a487b851bd94e858e389) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(7b2235f48914a487b851bd94e858e389).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(7b2235f48914a487b851bd94e858e389) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
9f5ad1a930c224922df1baad44b426b8.
[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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
7b2235f48914a487b851bd94e858e389.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(c7ac969b0260d6e873a4f9338af4787d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(9f5ad1a930c224922df1baad44b426b8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(7b2235f48914a487b851bd94e858e389) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(a7819293fefa879f16b2a6893c54a8b5) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(a7819293fefa879f16b2a6893c54a8b5).
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(a7819293fefa879f16b2a6893c54a8b5) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
a7819293fefa879f16b2a6893c54a8b5.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(a7819293fefa879f16b2a6893c54a8b5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1217143709-ed6b2421
(4b4e630cd766a41fa899497075bf16c8) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job 4b4e630cd766a41fa899497075bf16c8.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
4b4e630cd766a41fa899497075bf16c8 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1217143709-ed6b2421(4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 4b4e630cd766a41fa899497075bf16c8.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
ecdef92deb0a9fad9f39314d3926336f: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager b8b2fffdde2e336a2c588cd5b10c48e2@akka://flink/user/jobmanager_231
for job 4b4e630cd766a41fa899497075bf16c8 from the resource manager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
4b4e630cd766a41fa899497075bf16c8 with leader id
b8b2fffdde2e336a2c588cd5b10c48e2 lost leadership.
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherda217614-8736-4998-b1dc-548d626d465e.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherda217614-8736-4998-b1dc-548d626d465e.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{67b821976b5bb389f3c98a4e00210d05}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{95d7cf96397569fd9f7df119ffd67752}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{1b1f5b3e3a08567b0b9e4ac9b5d6f850}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{bbab6e32b505eb3de71d41d426cf5aff}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{547634b5d260579c088d630b20d2c9d4}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{8458990b0ee6d2e762fec09096343b3e}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{afdc9b676ff00eafe42b315e7502a2ca}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{1e50c86d1b9dcd3bb5f313c46bb85dcb}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{b1e06de1241bf368c530eed83c6fba0e}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{254411089cd0c44db5e7bddc519622dc}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{cc0074d5c7d776128d832a76b15372b3}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{5e0921df667e7e38f4b0be3ae1e1c2ab}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:11, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{3da6c68cd90ac345d33f299a33bb6d70}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{942a2562b604503a37225fa2b43a11a7}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherda217614-8736-4998-b1dc-548d626d465e.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{94e9f8e4cb4ffb8379f318a7b2d38b24}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-6] 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{1a4ac2489816afaf501b14192878176a}, jobId:
4b4e630cd766a41fa899497075bf16c8).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
4b4e630cd766a41fa899497075bf16c8 from job leader monitoring.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 4b4e630cd766a41fa899497075bf16c8.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 4b4e630cd766a41fa899497075bf16c8.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_230.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-4128e8f6-15bd-40a2-b002-b21d6970675f
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[ForkJoinPool.commonPool-worker-4] 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.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_230.
[ForkJoinPool.commonPool-worker-4] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:44077
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 7848 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@2c94c1a9
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1217143709-ed6b2421_0d4f7373-43bf-460f-bb12-504fa31dd7f4/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-1217143709-ed6b2421_0d4f7373-43bf-460f-bb12-504fa31dd7f4/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:33295
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:46185
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.493 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.934 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
> FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
(Thread[Task worker for ':' Thread 8,5,main]) completed. Took 36 mins 51.06
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 40m 17s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/rcnxr6in5bite
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]
