See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/211/display/redirect?page=changes>
Changes:
[dwysakowicz] [BEAM-2873] Setting number of shards for writes with runner
determined
[iemejia] [BEAM-6235] Upgrade AutoValue to version 1.6.3
------------------------------------------
[...truncated 232.91 MB...]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
a3cf8b2ad9a8f9b0e15195261d2f9f7f.
[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)
(0fd70093ffd42544d69ac5a27d526d98) 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)
(0fd70093ffd42544d69ac5a27d526d98).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(0549fd9e1408330c37a762d82b6bde9e) 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)
(0fd70093ffd42544d69ac5a27d526d98) [FINISHED]
[flink-akka.actor.default-dispatcher-3] 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}
0fd70093ffd42544d69ac5a27d526d98.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (15/16) (832592fa4cd23642241723246cf565e7) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (15/16)
(832592fa4cd23642241723246cf565e7).
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16)
(832592fa4cd23642241723246cf565e7) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(4078580ba7b04c413a4ff05fe11ae0c1) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(783033728430fab28a0fa40d96c4f0aa) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/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} (7/16)
(783033728430fab28a0fa40d96c4f0aa).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(783033728430fab28a0fa40d96c4f0aa) [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
832592fa4cd23642241723246cf565e7.
[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}
783033728430fab28a0fa40d96c4f0aa.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(c74f64ac83727c130a708924cb5be5ed) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (7/16) (8be0512183b07c8fa42ef74c9157e53b) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (7/16)
(8be0512183b07c8fa42ef74c9157e53b).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16)
(8be0512183b07c8fa42ef74c9157e53b) [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
8be0512183b07c8fa42ef74c9157e53b.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16)
(97cb224157721c68d8601ac571e63ee1) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)
(693cc407529f54ab1187707117725457) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/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} (6/16)
(693cc407529f54ab1187707117725457).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)
(6739fed38ab554ded639b954a60392f9) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/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} (16/16)
(6739fed38ab554ded639b954a60392f9).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(02da2218d03842f1bdd6a379a092045f) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/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} (6/16)
(693cc407529f54ab1187707117725457) [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)
(d35d485676196eaac4d92586b2ea1f92) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/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} (16/16)
(6739fed38ab554ded639b954a60392f9) [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)
(d35d485676196eaac4d92586b2ea1f92).
[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}
693cc407529f54ab1187707117725457.
[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)
(d35d485676196eaac4d92586b2ea1f92) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (a3cf8b2ad9a8f9b0e15195261d2f9f7f) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (6/16) (5241c73e54cb8fd7bab6391dd1e85e5b) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (6/16)
(5241c73e54cb8fd7bab6391dd1e85e5b).
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16)
(5241c73e54cb8fd7bab6391dd1e85e5b) [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)
(126ad160b98bd5696f91e2b5e4575b09) 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)
(126ad160b98bd5696f91e2b5e4575b09).
[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}
6739fed38ab554ded639b954a60392f9.
[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)
(126ad160b98bd5696f91e2b5e4575b09) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16)
(0fd70093ffd42544d69ac5a27d526d98) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
d35d485676196eaac4d92586b2ea1f92.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (832592fa4cd23642241723246cf565e7) 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
5241c73e54cb8fd7bab6391dd1e85e5b.
[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}
126ad160b98bd5696f91e2b5e4575b09.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (5ddbaabfa8b0b15f7cefffee71d9982d) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(5ddbaabfa8b0b15f7cefffee71d9982d).
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (a6bf382fc5d2b23391a02d1667ea42ea) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (16/16)
(a6bf382fc5d2b23391a02d1667ea42ea).
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(5ddbaabfa8b0b15f7cefffee71d9982d) [FINISHED]
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16)
(a6bf382fc5d2b23391a02d1667ea42ea) [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
5ddbaabfa8b0b15f7cefffee71d9982d.
[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
a6bf382fc5d2b23391a02d1667ea42ea.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (9/16) (c0feeee9b117864a1c67a911cae3c425) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (9/16)
(c0feeee9b117864a1c67a911cae3c425).
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16)
(c0feeee9b117864a1c67a911cae3c425) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
c0feeee9b117864a1c67a911cae3c425.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(783033728430fab28a0fa40d96c4f0aa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(8be0512183b07c8fa42ef74c9157e53b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)
(693cc407529f54ab1187707117725457) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)
(6739fed38ab554ded639b954a60392f9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(d35d485676196eaac4d92586b2ea1f92) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(5241c73e54cb8fd7bab6391dd1e85e5b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)
(126ad160b98bd5696f91e2b5e4575b09) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (5ddbaabfa8b0b15f7cefffee71d9982d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (a6bf382fc5d2b23391a02d1667ea42ea) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16)
(c0feeee9b117864a1c67a911cae3c425) 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)
(f56a7157a43023cec696593c4a957cb5) 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)
(f56a7157a43023cec696593c4a957cb5).
[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)
(f56a7157a43023cec696593c4a957cb5) [FINISHED]
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (1ac28a3a95805ad1aa49c00f4c5c3a83) switched from RUNNING
to FINISHED.
[flink-akka.actor.default-dispatcher-3] 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}
f56a7157a43023cec696593c4a957cb5.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(1ac28a3a95805ad1aa49c00f4c5c3a83).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(1ac28a3a95805ad1aa49c00f4c5c3a83) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
1ac28a3a95805ad1aa49c00f4c5c3a83.
[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)
(f56a7157a43023cec696593c4a957cb5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(1ac28a3a95805ad1aa49c00f4c5c3a83) 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 -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(afa785513fb25192a573a141743b223d) 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)
(afa785513fb25192a573a141743b223d).
[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)
(3837fcc3118e6ccbd867fd2a6d1a0a65) 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)
(3837fcc3118e6ccbd867fd2a6d1a0a65).
[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)
(afa785513fb25192a573a141743b223d) [FINISHED]
[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)
(3837fcc3118e6ccbd867fd2a6d1a0a65) [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)
(7d9a064b0eabb9ea9c6110726e81f3ca) 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}
afa785513fb25192a573a141743b223d.
[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)
(7d9a064b0eabb9ea9c6110726e81f3ca).
[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)
(7d9a064b0eabb9ea9c6110726e81f3ca) [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)
(3b7d405a2a87bbd263eb71720a8ee8c4) 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)
(3b7d405a2a87bbd263eb71720a8ee8c4).
[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)
(3b7d405a2a87bbd263eb71720a8ee8c4) [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}
3837fcc3118e6ccbd867fd2a6d1a0a65.
[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}
7d9a064b0eabb9ea9c6110726e81f3ca.
[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}
3b7d405a2a87bbd263eb71720a8ee8c4.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(afa785513fb25192a573a141743b223d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(3837fcc3118e6ccbd867fd2a6d1a0a65) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(7d9a064b0eabb9ea9c6110726e81f3ca) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(3b7d405a2a87bbd263eb71720a8ee8c4) 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)
(7ab27fb2170875414398444532c825a3) 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)
(f6dd6d13264bc829a4c05985546974ce) 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)
(7ab27fb2170875414398444532c825a3).
[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)
(f6dd6d13264bc829a4c05985546974ce).
[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)
(ec6306edf70791d6fc71e3ad3fc305f8) 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 - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(7ab27fb2170875414398444532c825a3) [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)
(ec6306edf70791d6fc71e3ad3fc305f8).
[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)
(f6dd6d13264bc829a4c05985546974ce) [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)
(ec6306edf70791d6fc71e3ad3fc305f8) [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)
(991aa3925cae8484def1e8b249bd4f10) 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)
(c08eb4fbda267106dfefdc658d6c78bd) 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)
(c08eb4fbda267106dfefdc658d6c78bd).
[flink-akka.actor.default-dispatcher-3] 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}
7ab27fb2170875414398444532c825a3.
[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)
(991aa3925cae8484def1e8b249bd4f10).
[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)
(c08eb4fbda267106dfefdc658d6c78bd) [FINISHED]
[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)
(991aa3925cae8484def1e8b249bd4f10) [FINISHED]
[flink-akka.actor.default-dispatcher-3] 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}
f6dd6d13264bc829a4c05985546974ce.
[flink-akka.actor.default-dispatcher-3] 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}
ec6306edf70791d6fc71e3ad3fc305f8.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(7ab27fb2170875414398444532c825a3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] 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}
c08eb4fbda267106dfefdc658d6c78bd.
[flink-akka.actor.default-dispatcher-3] 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}
991aa3925cae8484def1e8b249bd4f10.
[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)
(f6dd6d13264bc829a4c05985546974ce) 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} (1/16)
(ec6306edf70791d6fc71e3ad3fc305f8) 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} (14/16)
(c08eb4fbda267106dfefdc658d6c78bd) 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)
(7658f0c268134a5eb87641c3dcdc6549) 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)
(7658f0c268134a5eb87641c3dcdc6549).
[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)
(aebb00f9e51eae0c30136589952f5bfa) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(7658f0c268134a5eb87641c3dcdc6549) [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)
(aebb00f9e51eae0c30136589952f5bfa).
[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)
(aebb00f9e51eae0c30136589952f5bfa) [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} (10/16)
(991aa3925cae8484def1e8b249bd4f10) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
7658f0c268134a5eb87641c3dcdc6549.
[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)
(0f25f9bb0309babb201852e6a9a83d5c) 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)
(0f25f9bb0309babb201852e6a9a83d5c).
[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)
(0f25f9bb0309babb201852e6a9a83d5c) [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}
aebb00f9e51eae0c30136589952f5bfa.
[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}
0f25f9bb0309babb201852e6a9a83d5c.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(7658f0c268134a5eb87641c3dcdc6549) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(aebb00f9e51eae0c30136589952f5bfa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(0f25f9bb0309babb201852e6a9a83d5c) 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 -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(8a182baa019d845705196200d552a21b) 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)
(8a182baa019d845705196200d552a21b).
[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)
(8a182baa019d845705196200d552a21b) [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)
(67ad8820da0d64b5968a89ad4a86c814) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
8a182baa019d845705196200d552a21b.
[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)
(67ad8820da0d64b5968a89ad4a86c814).
[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)
(67ad8820da0d64b5968a89ad4a86c814) [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}
67ad8820da0d64b5968a89ad4a86c814.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(8a182baa019d845705196200d552a21b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(67ad8820da0d64b5968a89ad4a86c814) 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)
(1d49603e4a11e7cb76292a062d7224f6) 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)
(1d49603e4a11e7cb76292a062d7224f6).
[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)
(1d49603e4a11e7cb76292a062d7224f6) [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}
1d49603e4a11e7cb76292a062d7224f6.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(1d49603e4a11e7cb76292a062d7224f6) 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)
(ab1012e6aa006714c30aed7078048fd9) 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)
(ab1012e6aa006714c30aed7078048fd9).
[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)
(ab1012e6aa006714c30aed7078048fd9) [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}
ab1012e6aa006714c30aed7078048fd9.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(ab1012e6aa006714c30aed7078048fd9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1217160657-bf6fa2d6
(242c29c430dec25fcd49aa145e781d6e) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job 242c29c430dec25fcd49aa145e781d6e.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
242c29c430dec25fcd49aa145e781d6e reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1217160657-bf6fa2d6(242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 242c29c430dec25fcd49aa145e781d6e.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
19bb8debc473ba9fe74538e372441de5: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager 9eab3455383a33533154cec2e5384757@akka://flink/user/jobmanager_231
for job 242c29c430dec25fcd49aa145e781d6e from the resource manager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping 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.taskexecutor.TaskExecutor - JobManager for job
242c29c430dec25fcd49aa145e781d6e with leader id
9eab3455383a33533154cec2e5384757 lost leadership.
[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.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherdb155c3d-b350-4211-a3a3-cac62a9dd59e.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-6] 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{7a5819f0cff4f050f45a15e3dbebdb4f}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherdb155c3d-b350-4211-a3a3-cac62a9dd59e.
[flink-akka.actor.default-dispatcher-6] 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{2dadba0efadbdb72bb2a48e0cc50cbe4}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{f12a33d23f2b4a24dee2f422feedcaa1}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{98c592ed4f45c638e0d59bebe5e1547e}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{9c46c6fce7a259dc753ecd877b0cd894}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{9ff8aadb10d6595aefbbcdae64143875}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{8d319a0c2a52d2c87478ecdd54e9c40e}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{4197ad8dd63785399cda5dc5cb4b2f5e}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{57f1fecf35e0e60e2086889e5118c207}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{28dd64566ae8d0c325aeae2a11723c94}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{41dd7cedb8b715004029f963f58a9fd6}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{8ec1344634049a0e3ea913c2ad8e9fd8}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{ae6a747a27a3107ffa24dc3893402ac5}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-6] 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{5519d0a11ba67a933f87546296c53b99}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{dd5212efd1ff1410f49685473de81e04}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{c7edebce43966239725b0cb9f41770f3}, jobId:
242c29c430dec25fcd49aa145e781d6e).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
242c29c430dec25fcd49aa145e781d6e from job leader monitoring.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 242c29c430dec25fcd49aa145e781d6e.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_230.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-c110a895-afe3-42ce-9a88-8ea7c3cdee70
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[ForkJoinPool.commonPool-worker-13] 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/dispatcherdb155c3d-b350-4211-a3a3-cac62a9dd59e.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_230.
[flink-akka.actor.default-dispatcher-4] 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:34471
[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 7853 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@1ac2e340
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1217160657-bf6fa2d6_3e057ebe-601e-47f5-a9a9-acdc68fa2aae/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-1217160657-bf6fa2d6_3e057ebe-601e-47f5-a9a9-acdc68fa2aae/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:35297
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:40665
Gradle Test Executor 2 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.494 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.915 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
> FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
(Thread[Task worker for ':' Thread 8,5,main]) completed. Took 37 mins 14.726
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 39m 48s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/2gepoijilqnoe
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]
