See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/212/display/redirect?page=changes>
Changes:
[aromanenko.dev] [BEAM-6200] Deprecate old HadoopInputFormatIO, move it into new
------------------------------------------
[...truncated 232.27 MB...]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (f95aa58371aa607170a325ee104acb53) 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 - 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)
(b72e1bc4549fe21f5f13c0f3c43c8584) [FINISHED]
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (df565f1285702ccbb6d3e916847e200c) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (16/16)
(df565f1285702ccbb6d3e916847e200c).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16)
(2fb73c274b31f4f3f5cdd05002d38ce5) 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/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
b72e1bc4549fe21f5f13c0f3c43c8584.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16)
(df565f1285702ccbb6d3e916847e200c) [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)
(da4a5e30aef32ca55ff44b1cc9c6200b) 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)
(da4a5e30aef32ca55ff44b1cc9c6200b).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(fbc936cdb1395195761356f3cf909c57) 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 - 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)
(da4a5e30aef32ca55ff44b1cc9c6200b) [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
df565f1285702ccbb6d3e916847e200c.
[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}
da4a5e30aef32ca55ff44b1cc9c6200b.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (3/16) (ba25c4836c0c6c660abf7d845d0ecbc9) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (3/16)
(ba25c4836c0c6c660abf7d845d0ecbc9).
[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} (16/16)
(d29d3a0f79d816540f277dab445372ef) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16)
(ba25c4836c0c6c660abf7d845d0ecbc9) [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
ba25c4836c0c6c660abf7d845d0ecbc9.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (14/16) (a2f3a8049d04f94348ebebef80260a74) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (14/16)
(a2f3a8049d04f94348ebebef80260a74).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16)
(a2f3a8049d04f94348ebebef80260a74) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
a2f3a8049d04f94348ebebef80260a74.
[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)
(b72e1bc4549fe21f5f13c0f3c43c8584) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (df565f1285702ccbb6d3e916847e200c) 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} (14/16)
(da4a5e30aef32ca55ff44b1cc9c6200b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16)
(ba25c4836c0c6c660abf7d845d0ecbc9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (a2f3a8049d04f94348ebebef80260a74) 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 -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(ec3811618ebf05cbc4ed1e85feb8ad51) 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)
(ec3811618ebf05cbc4ed1e85feb8ad51).
[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)
(ec3811618ebf05cbc4ed1e85feb8ad51) [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}
ec3811618ebf05cbc4ed1e85feb8ad51.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (9155078f3d28bf19b19fe7e6efdd91c6) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(9155078f3d28bf19b19fe7e6efdd91c6).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16)
(9155078f3d28bf19b19fe7e6efdd91c6) [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
9155078f3d28bf19b19fe7e6efdd91c6.
[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)
(ec3811618ebf05cbc4ed1e85feb8ad51) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (9155078f3d28bf19b19fe7e6efdd91c6) 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 -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(c1a060f0022fcfa8b9dab622e39c62ce) 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)
(c1a060f0022fcfa8b9dab622e39c62ce).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(4a2110338395f8924eb899352e7deeaa) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/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} (12/16)
(4a2110338395f8924eb899352e7deeaa).
[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)
(c1a060f0022fcfa8b9dab622e39c62ce) [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 -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16)
(6642580731520cc9e9ea1982dd975940) 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 - Freeing task resources for
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16)
(6642580731520cc9e9ea1982dd975940).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/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} (12/16)
(4a2110338395f8924eb899352e7deeaa) [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)
(6642580731520cc9e9ea1982dd975940) [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}
c1a060f0022fcfa8b9dab622e39c62ce.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (4e3be2eb0a85c87d1f14e78fc3048df7) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(4e3be2eb0a85c87d1f14e78fc3048df7).
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(4e3be2eb0a85c87d1f14e78fc3048df7) [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}
4a2110338395f8924eb899352e7deeaa.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (12/16) (a593c5afa36ab55085ddee08d95f8d17) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (15/16) (59f131385917dd35f8752b7026bcd94d) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (12/16)
(a593c5afa36ab55085ddee08d95f8d17).
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (15/16)
(59f131385917dd35f8752b7026bcd94d).
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16)
(a593c5afa36ab55085ddee08d95f8d17) [FINISHED]
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16)
(59f131385917dd35f8752b7026bcd94d) [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}
6642580731520cc9e9ea1982dd975940.
[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)
(c1a060f0022fcfa8b9dab622e39c62ce) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
4e3be2eb0a85c87d1f14e78fc3048df7.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
a593c5afa36ab55085ddee08d95f8d17.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
59f131385917dd35f8752b7026bcd94d.
[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} (12/16)
(4a2110338395f8924eb899352e7deeaa) 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} (15/16)
(6642580731520cc9e9ea1982dd975940) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (4e3be2eb0a85c87d1f14e78fc3048df7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (a593c5afa36ab55085ddee08d95f8d17) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (59f131385917dd35f8752b7026bcd94d) 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)
(0557849fc76a482d7af6e4a616a98e8e) 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)
(0557849fc76a482d7af6e4a616a98e8e).
[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)
(0557849fc76a482d7af6e4a616a98e8e) [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}
0557849fc76a482d7af6e4a616a98e8e.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (ef4a8909be10110e2f9de665a19e8bd8) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(ef4a8909be10110e2f9de665a19e8bd8).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(ef4a8909be10110e2f9de665a19e8bd8) [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
ef4a8909be10110e2f9de665a19e8bd8.
[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} (2/16)
(0557849fc76a482d7af6e4a616a98e8e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(ef4a8909be10110e2f9de665a19e8bd8) 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 -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(bdbb558c1918c82e75f06c7ed7f32421) 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)
(bdbb558c1918c82e75f06c7ed7f32421).
[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)
(1bd613c6eea00cd8e668c177b5871e84) 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)
(1bd613c6eea00cd8e668c177b5871e84).
[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)
(bdbb558c1918c82e75f06c7ed7f32421) [FINISHED]
[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)
(1bd613c6eea00cd8e668c177b5871e84) [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)
(ddc61d8a5fb2767f140b9f3b5c729dc5) switched from RUNNING to FINISHED.
[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)
(ddc61d8a5fb2767f140b9f3b5c729dc5).
[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}
bdbb558c1918c82e75f06c7ed7f32421.
[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)
(ddc61d8a5fb2767f140b9f3b5c729dc5) [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)
(cec73d709c625e8181c7c1b979175132) 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)
(cec73d709c625e8181c7c1b979175132).
[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)
(fa635bf1dad6a6368bde57edb72ef0d3) 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 - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(cec73d709c625e8181c7c1b979175132) [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)
(fa635bf1dad6a6368bde57edb72ef0d3).
[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)
(b644a12cdf93f75b1840967397d2c1ee) 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)
(b644a12cdf93f75b1840967397d2c1ee).
[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)
(fa635bf1dad6a6368bde57edb72ef0d3) [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)
(b644a12cdf93f75b1840967397d2c1ee) [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}
1bd613c6eea00cd8e668c177b5871e84.
[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}
ddc61d8a5fb2767f140b9f3b5c729dc5.
[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}
cec73d709c625e8181c7c1b979175132.
[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}
fa635bf1dad6a6368bde57edb72ef0d3.
[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)
(bdbb558c1918c82e75f06c7ed7f32421) 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}
b644a12cdf93f75b1840967397d2c1ee.
[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)
(1bd613c6eea00cd8e668c177b5871e84) 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} (7/16)
(ddc61d8a5fb2767f140b9f3b5c729dc5) 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)
(9b975e80b222cda5dbd74d3b40201436) 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)
(9b975e80b222cda5dbd74d3b40201436).
[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)
(9b975e80b222cda5dbd74d3b40201436) [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)
(f3602bea8845190b9732c1c89d0204f0) 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)
(f3602bea8845190b9732c1c89d0204f0).
[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)
(f3602bea8845190b9732c1c89d0204f0) [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} (14/16)
(cec73d709c625e8181c7c1b979175132) 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/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
9b975e80b222cda5dbd74d3b40201436.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(fa635bf1dad6a6368bde57edb72ef0d3) 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/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
f3602bea8845190b9732c1c89d0204f0.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(b644a12cdf93f75b1840967397d2c1ee) 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} (16/16)
(9b975e80b222cda5dbd74d3b40201436) 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} (11/16)
(f3602bea8845190b9732c1c89d0204f0) 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)
(8d15cdfa79d6a549abf8d00c00df4aba) 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)
(8d15cdfa79d6a549abf8d00c00df4aba).
[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)
(8d15cdfa79d6a549abf8d00c00df4aba) [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}
8d15cdfa79d6a549abf8d00c00df4aba.
[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)
(8d15cdfa79d6a549abf8d00c00df4aba) 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)
(c0f13d41207f38b01133ffa4cde4aa1e) 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)
(c0f13d41207f38b01133ffa4cde4aa1e).
[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)
(c0f13d41207f38b01133ffa4cde4aa1e) [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}
c0f13d41207f38b01133ffa4cde4aa1e.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(c0f13d41207f38b01133ffa4cde4aa1e) 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 -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(600961a5764f8a4c3c456a32a6636ec0) 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)
(600961a5764f8a4c3c456a32a6636ec0).
[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)
(600961a5764f8a4c3c456a32a6636ec0) [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)
(cc5d84c3d3264f57070a993158973f4a) 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)
(cc5d84c3d3264f57070a993158973f4a).
[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}
600961a5764f8a4c3c456a32a6636ec0.
[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)
(cc5d84c3d3264f57070a993158973f4a) [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}
cc5d84c3d3264f57070a993158973f4a.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(600961a5764f8a4c3c456a32a6636ec0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(cc5d84c3d3264f57070a993158973f4a) 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)
(86c095197e138016510aa7301f8d6f4c) 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)
(86c095197e138016510aa7301f8d6f4c).
[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)
(86c095197e138016510aa7301f8d6f4c) [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}
86c095197e138016510aa7301f8d6f4c.
[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)
(86c095197e138016510aa7301f8d6f4c) 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)
(db23e45e2759404b3a4879c48e97a09e) 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)
(db23e45e2759404b3a4879c48e97a09e).
[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)
(db23e45e2759404b3a4879c48e97a09e) [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}
db23e45e2759404b3a4879c48e97a09e.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(db23e45e2759404b3a4879c48e97a09e) 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)
(abce789bb2a76bbb9b883600961cbdf7) 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)
(abce789bb2a76bbb9b883600961cbdf7).
[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)
(abce789bb2a76bbb9b883600961cbdf7) [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}
abce789bb2a76bbb9b883600961cbdf7.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(abce789bb2a76bbb9b883600961cbdf7) 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)
(1eaa5c449de2ef9ed830838cefec611b) 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)
(1eaa5c449de2ef9ed830838cefec611b).
[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)
(1eaa5c449de2ef9ed830838cefec611b) [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}
1eaa5c449de2ef9ed830838cefec611b.
[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)
(1eaa5c449de2ef9ed830838cefec611b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1217170510-99270543
(8ed0eed0f2e2cbc3dd59cf099b87e499) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job 8ed0eed0f2e2cbc3dd59cf099b87e499.
[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
8ed0eed0f2e2cbc3dd59cf099b87e499 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1217170510-99270543(8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 8ed0eed0f2e2cbc3dd59cf099b87e499.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
b37eca7e7b8e849141561415c01c9b7a: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager a92f1089bf9416eff5793e2331854a98@akka://flink/user/jobmanager_231
for job 8ed0eed0f2e2cbc3dd59cf099b87e499 from the resource manager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
8ed0eed0f2e2cbc3dd59cf099b87e499 with leader id
a92f1089bf9416eff5793e2331854a98 lost leadership.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher3e44cebf-6a46-4be2-9904-7268a053d12f.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher3e44cebf-6a46-4be2-9904-7268a053d12f.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{7239bf4d33a09b35fc5982bf2917e68b}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{1bf47ba3e865a01f637d98c21584adf9}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{4b9f7823ab48b8bace58573566c01298}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{2407954f940bacc612f1854bce155ce4}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{8d9557917cb172b619acf402f669e953}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{8fb915c3dc6764af8a3daa8b8ad459c2}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{8b2c0e52fa972a3876a2f53c807d63e1}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{13f5f57fea66a8ad698fbe295221c098}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{b48556ba8987c46e83f6b58ac532e7dd}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:11, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{8b2353c606bad5db46a0d4adcb31aa8a}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{a16c76ee25e93b44e771ad827b7882c8}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{06f5cebd1d1c95fd48bb2cb4717e311e}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{d6f67fe19ee525b55ce690070be4bd3d}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{819d68bb6a83a0ecc615935cf6cf813e}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{55363d1f188c4bd5114a49e947adf4d9}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{03ec17ad58baada11aae247dd437aa86}, jobId:
8ed0eed0f2e2cbc3dd59cf099b87e499).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
8ed0eed0f2e2cbc3dd59cf099b87e499 from job leader monitoring.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 8ed0eed0f2e2cbc3dd59cf099b87e499.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_230.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-b004c050-798d-4310-a09f-48aeff25eee9
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[ForkJoinPool.commonPool-worker-11] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher3e44cebf-6a46-4be2-9904-7268a053d12f.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_230.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:36951
[flink-akka.actor.default-dispatcher-5] 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 10450 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@66a1f181
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1217170510-99270543_fe5c4454-9001-4042-9351-772d763b7949/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-1217170510-99270543_fe5c4454-9001-4042-9351-772d763b7949/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:41065
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:33563
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 (2.621 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.961 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 9,5,main]) completed. Took 44 mins 55.007
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 47m 22s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/pp4ailb4a23cu
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]
