See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/208/display/redirect>
------------------------------------------
[...truncated 232.80 MB...]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (6/16) (d07eb5e32fd70adeb16b4f3a22482a2c) switched from RUNNING
to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/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} (15/16)
(beabeae31671c89160c18d7b33d7bc78) [FINISHED]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (6/16)
(d07eb5e32fd70adeb16b4f3a22482a2c).
[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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
beabeae31671c89160c18d7b33d7bc78.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16)
(d07eb5e32fd70adeb16b4f3a22482a2c) [FINISHED]
[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} (6/16)
(6102590e7809a4053236d7b04b73b377) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)
(3637bdf33924182981ead2c92c87204d) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/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} (4/16)
(3637bdf33924182981ead2c92c87204d).
[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
d07eb5e32fd70adeb16b4f3a22482a2c.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/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} (4/16)
(3637bdf33924182981ead2c92c87204d) [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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
3637bdf33924182981ead2c92c87204d.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (15/16) (17fcceba8a2355ae9a297ffed75896d3) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (15/16)
(17fcceba8a2355ae9a297ffed75896d3).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16)
(beabeae31671c89160c18d7b33d7bc78) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16)
(17fcceba8a2355ae9a297ffed75896d3) [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 -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(4ae8d300c6a60cf8f3cfd2eb9e007a2f) 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
17fcceba8a2355ae9a297ffed75896d3.
[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)
(4ae8d300c6a60cf8f3cfd2eb9e007a2f).
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (4/16) (4cd575e79feb353943b8e68aa0117ade) switched from RUNNING
to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(d07eb5e32fd70adeb16b4f3a22482a2c) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (4/16)
(4cd575e79feb353943b8e68aa0117ade).
[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)
(4ae8d300c6a60cf8f3cfd2eb9e007a2f) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(aee01e71fc73a2a1d53f103bd240b180) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/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} (14/16)
(aee01e71fc73a2a1d53f103bd240b180).
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16)
(4cd575e79feb353943b8e68aa0117ade) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(aee01e71fc73a2a1d53f103bd240b180) [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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
4ae8d300c6a60cf8f3cfd2eb9e007a2f.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)
(3637bdf33924182981ead2c92c87204d) 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
4cd575e79feb353943b8e68aa0117ade.
[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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
aee01e71fc73a2a1d53f103bd240b180.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (17fcceba8a2355ae9a297ffed75896d3) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (ca6466ec4b8db4315376c1bd4a6318ea) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(ca6466ec4b8db4315376c1bd4a6318ea).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16)
(ca6466ec4b8db4315376c1bd4a6318ea) [FINISHED]
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (14/16) (93a24338943c244df071f8d41b6f6bf5) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (14/16)
(93a24338943c244df071f8d41b6f6bf5).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(4ae8d300c6a60cf8f3cfd2eb9e007a2f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
ca6466ec4b8db4315376c1bd4a6318ea.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16)
(93a24338943c244df071f8d41b6f6bf5) [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)
(4bf4c74366e554e7f41f4a5dc061cbf5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16)
(4cd575e79feb353943b8e68aa0117ade) switched from RUNNING to 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 - Freeing task resources for
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(4bf4c74366e554e7f41f4a5dc061cbf5).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
93a24338943c244df071f8d41b6f6bf5.
[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)
(4bf4c74366e554e7f41f4a5dc061cbf5) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)
(5a6803bf02457a5c767a9206dbfdff75) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/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} (9/16)
(5a6803bf02457a5c767a9206dbfdff75).
[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/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
4bf4c74366e554e7f41f4a5dc061cbf5.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/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} (9/16)
(5a6803bf02457a5c767a9206dbfdff75) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(aee01e71fc73a2a1d53f103bd240b180) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (ca6466ec4b8db4315376c1bd4a6318ea) 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/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
5a6803bf02457a5c767a9206dbfdff75.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (93a24338943c244df071f8d41b6f6bf5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(4bf4c74366e554e7f41f4a5dc061cbf5) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (bf79be60a28ac9397329e13dc4028b1a) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (9/16) (b5ffdb5a431466b3d3161c38d3472619) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(bf79be60a28ac9397329e13dc4028b1a).
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (9/16)
(b5ffdb5a431466b3d3161c38d3472619).
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16)
(b5ffdb5a431466b3d3161c38d3472619) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
b5ffdb5a431466b3d3161c38d3472619.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(bf79be60a28ac9397329e13dc4028b1a) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)
(5a6803bf02457a5c767a9206dbfdff75) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
bf79be60a28ac9397329e13dc4028b1a.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16)
(b5ffdb5a431466b3d3161c38d3472619) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (bf79be60a28ac9397329e13dc4028b1a) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(5d3b76c5e3171b1da1720bf121139c5b) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/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} (8/16)
(5d3b76c5e3171b1da1720bf121139c5b).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(5d3b76c5e3171b1da1720bf121139c5b) [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$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
5d3b76c5e3171b1da1720bf121139c5b.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (b434f153bd164fb7bec4e7dab632ffec) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (8/16)
(b434f153bd164fb7bec4e7dab632ffec).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(5d3b76c5e3171b1da1720bf121139c5b) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16)
(b434f153bd164fb7bec4e7dab632ffec) [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
b434f153bd164fb7bec4e7dab632ffec.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(b434f153bd164fb7bec4e7dab632ffec) 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)
(fa5ec18b59aa17547f0d68ab17685b1f) 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)
(fa5ec18b59aa17547f0d68ab17685b1f).
[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)
(fa5ec18b59aa17547f0d68ab17685b1f) [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}
fa5ec18b59aa17547f0d68ab17685b1f.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (afb1e77791850093c8ed433dc6374c44) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(afb1e77791850093c8ed433dc6374c44).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(afb1e77791850093c8ed433dc6374c44) [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
afb1e77791850093c8ed433dc6374c44.
[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)
(fa5ec18b59aa17547f0d68ab17685b1f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(afb1e77791850093c8ed433dc6374c44) 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)
(0f6a5e3e3ab9b0b659ed36c7947bc3d7) 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)
(0f6a5e3e3ab9b0b659ed36c7947bc3d7).
[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)
(0f6a5e3e3ab9b0b659ed36c7947bc3d7) [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}
0f6a5e3e3ab9b0b659ed36c7947bc3d7.
[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)
(f9af01c155b3846cc9670722e5e648b0) 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)
(f9af01c155b3846cc9670722e5e648b0).
[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)
(f9af01c155b3846cc9670722e5e648b0) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
f9af01c155b3846cc9670722e5e648b0.
[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)
(871d365e38582342e9ffddab19923d31) 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)
(871d365e38582342e9ffddab19923d31).
[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)
(871d365e38582342e9ffddab19923d31) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(0f6a5e3e3ab9b0b659ed36c7947bc3d7) 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 -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(422e752f51d895065cdae2175703de78) 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)
(422e752f51d895065cdae2175703de78).
[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)
(422e752f51d895065cdae2175703de78) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
871d365e38582342e9ffddab19923d31.
[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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
422e752f51d895065cdae2175703de78.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(f9af01c155b3846cc9670722e5e648b0) 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} (5/16)
(871d365e38582342e9ffddab19923d31) 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 -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(3f4c289c19b1de494dc29c3908768557) 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)
(3f4c289c19b1de494dc29c3908768557).
[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)
(422e752f51d895065cdae2175703de78) 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 - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(3f4c289c19b1de494dc29c3908768557) [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}
3f4c289c19b1de494dc29c3908768557.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(3f4c289c19b1de494dc29c3908768557) 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 -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(ee0c1d911c6a2e4e9b3ddaf86306e675) 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)
(ee0c1d911c6a2e4e9b3ddaf86306e675).
[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)
(7f3eb04b9705eef0091e7605798b13cc) 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)
(7f3eb04b9705eef0091e7605798b13cc).
[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)
(ee0c1d911c6a2e4e9b3ddaf86306e675) [FINISHED]
[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)
(7f3eb04b9705eef0091e7605798b13cc) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
ee0c1d911c6a2e4e9b3ddaf86306e675.
[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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
7f3eb04b9705eef0091e7605798b13cc.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(ee0c1d911c6a2e4e9b3ddaf86306e675) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(7f3eb04b9705eef0091e7605798b13cc) 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 -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(07f3ef6a65c00cda1cdbfbd0e09286a8) 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)
(07f3ef6a65c00cda1cdbfbd0e09286a8).
[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)
(07f3ef6a65c00cda1cdbfbd0e09286a8) [FINISHED]
[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)
(b36f05d24b109857ae13ec51e3aba1e6) 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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
07f3ef6a65c00cda1cdbfbd0e09286a8.
[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)
(b36f05d24b109857ae13ec51e3aba1e6).
[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)
(b36f05d24b109857ae13ec51e3aba1e6) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
b36f05d24b109857ae13ec51e3aba1e6.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(07f3ef6a65c00cda1cdbfbd0e09286a8) 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)
(d17c9f1743209740e89caacf76898512) 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)
(d17c9f1743209740e89caacf76898512).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(b36f05d24b109857ae13ec51e3aba1e6) 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 - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(d17c9f1743209740e89caacf76898512) [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}
d17c9f1743209740e89caacf76898512.
[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)
(5af27e6bd0a75ac1782058c9c43b43b5) 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)
(5af27e6bd0a75ac1782058c9c43b43b5).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(d17c9f1743209740e89caacf76898512) 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)
(5af27e6bd0a75ac1782058c9c43b43b5) [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}
5af27e6bd0a75ac1782058c9c43b43b5.
[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)
(74430926d75bb290caeb1bbc085c890a) 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)
(74430926d75bb290caeb1bbc085c890a).
[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)
(74430926d75bb290caeb1bbc085c890a) [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}
74430926d75bb290caeb1bbc085c890a.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(5af27e6bd0a75ac1782058c9c43b43b5) 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)
(9a310682f6179b40c8f9841312e1482e) 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 - Freeing task resources for
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(9a310682f6179b40c8f9841312e1482e).
[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)
(9a310682f6179b40c8f9841312e1482e) [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/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
9a310682f6179b40c8f9841312e1482e.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(74430926d75bb290caeb1bbc085c890a) 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)
(5ba0f8ee9051db2f23dccd651548d2f1) 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)
(5ba0f8ee9051db2f23dccd651548d2f1).
[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)
(5ba0f8ee9051db2f23dccd651548d2f1) [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/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
5ba0f8ee9051db2f23dccd651548d2f1.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(9a310682f6179b40c8f9841312e1482e) 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)
(a51588fb6aa2392ef8242db43948988d) 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)
(a51588fb6aa2392ef8242db43948988d).
[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)
(a51588fb6aa2392ef8242db43948988d) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
a51588fb6aa2392ef8242db43948988d.
[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)
(5ba0f8ee9051db2f23dccd651548d2f1) 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} (8/16)
(a51588fb6aa2392ef8242db43948988d) 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)
(016e4ab31f3078c2c4eaf98083a05da5) 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)
(016e4ab31f3078c2c4eaf98083a05da5).
[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)
(016e4ab31f3078c2c4eaf98083a05da5) [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$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
016e4ab31f3078c2c4eaf98083a05da5.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(016e4ab31f3078c2c4eaf98083a05da5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1217133117-7a1b4c90
(ba0deca17fb799393588e518b84f9707) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job ba0deca17fb799393588e518b84f9707.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
ba0deca17fb799393588e518b84f9707 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1217133117-7a1b4c90(ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job ba0deca17fb799393588e518b84f9707.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
de3f6c1e6bfda895b97fb6cb920c96d1: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager abc2d069ff669b68b1e5b3390e364654@akka://flink/user/jobmanager_231
for job ba0deca17fb799393588e518b84f9707 from the resource manager.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher9223ca2b-7be4-42fc-b5e6-aa83893f5e02.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher9223ca2b-7be4-42fc-b5e6-aa83893f5e02.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
ba0deca17fb799393588e518b84f9707 with leader id
abc2d069ff669b68b1e5b3390e364654 lost leadership.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-5] 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{8197493bd62591a7b384113943141cff}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{7b89378ced2ca42728111c4688a2186c}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{b1fb09dca32e1b86dd343d33ee29ae72}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{c4902d119ab491b925256c72bac0a52c}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{4212f963728d8be2c1d051029eb96c8c}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{8fee94f48577d81cfe839366d7078e89}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{01f6799e1b70f8b68f734f0a6be55d40}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{2c0ee417238a0a2ea86c40996beef7a0}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{78bc7322e3ef8b43e6b8ed8ed1c6ebdf}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{6ca7d19d6031fb55f7d759cd9f3afe67}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] 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{2402ff71ea4a69c221b815fd13048c0c}, jobId:
ba0deca17fb799393588e518b84f9707).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_230.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-77b2f0b0-382a-4e61-bd89-90b6b77b5d70
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher9223ca2b-7be4-42fc-b5e6-aa83893f5e02.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_230.
[ForkJoinPool.commonPool-worker-4] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-4] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-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:34493
[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 8389 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@3e01f372
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1217133117-7a1b4c90_be68d59f-bf43-4289-8d51-427f215823ee/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-1217133117-7a1b4c90_be68d59f-bf43-4289-8d51-427f215823ee/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:42337
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:42625
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.547 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.967 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 7,5,main]) completed. Took 39 mins 38.392
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 43m 16s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/64xtm4lf6i67m
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]
