See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/216/display/redirect?page=changes>
Changes:
[dcrhodes] [BEAM-6190] Add processing stuck message to Pantheon.
[dcrhodes] Fixed some style errors and tests that needed an additional
parameter.
------------------------------------------
[...truncated 236.66 MB...]
[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)
(6fafba40efae6989a59f77b7fac4a4f0) 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)
(6fafba40efae6989a59f77b7fac4a4f0).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(ed04b52fdbaf2a2fd05f57fc3ccfd3d5) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(ed04b52fdbaf2a2fd05f57fc3ccfd3d5).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)
(6229c9e6cffc640764f9cd13841b9528) 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)
(6fafba40efae6989a59f77b7fac4a4f0) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/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} (11/16)
(6229c9e6cffc640764f9cd13841b9528).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(ed04b52fdbaf2a2fd05f57fc3ccfd3d5) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(f925574d9c2e910f92fa80b5843ffb99) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)
(6229c9e6cffc640764f9cd13841b9528) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(9fbfae63c360df8e0efb6964456ac8a4) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (6/16) (27b050d2b5b5df72e2a47cafc58d6fe0) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (6/16)
(27b050d2b5b5df72e2a47cafc58d6fe0).
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16)
(27b050d2b5b5df72e2a47cafc58d6fe0) [FINISHED]
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (0b05e20f1f94a34aae05086f97fbe0fa) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (8/16)
(0b05e20f1f94a34aae05086f97fbe0fa).
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16)
(0b05e20f1f94a34aae05086f97fbe0fa) [FINISHED]
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (11/16) (c6880887c150a0b6292350579b07a00e) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (11/16)
(c6880887c150a0b6292350579b07a00e).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(44f0e44ca9633091f2fd0404068f4ab2) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16)
(c6880887c150a0b6292350579b07a00e) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (529499b718e86d3efe4c1da04a483f78) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(9dda9fa285e1c76a363013d0ed7928a5) 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
698ec825f450edb5b3601e596b286d1b.
[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}
6fafba40efae6989a59f77b7fac4a4f0.
[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)
(fa3da7afc66055a0c191eb95651a0198) 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)
(fa3da7afc66055a0c191eb95651a0198).
[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)
(fa3da7afc66055a0c191eb95651a0198) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (698ec825f450edb5b3601e596b286d1b) 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}
ed04b52fdbaf2a2fd05f57fc3ccfd3d5.
[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}
6229c9e6cffc640764f9cd13841b9528.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (15/16) (a4b198fb95600d832ca46261b0939a37) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (15/16)
(a4b198fb95600d832ca46261b0939a37).
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16)
(a4b198fb95600d832ca46261b0939a37) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)
(6fafba40efae6989a59f77b7fac4a4f0) 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 -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)
(c44c01bd20bd99d5aaa5279d2b3fc687) 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)
(c44c01bd20bd99d5aaa5279d2b3fc687).
[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)
(c44c01bd20bd99d5aaa5279d2b3fc687) [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
27b050d2b5b5df72e2a47cafc58d6fe0.
[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
0b05e20f1f94a34aae05086f97fbe0fa.
[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
c6880887c150a0b6292350579b07a00e.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(6284a857d0b14e06c41c41b3c49b3869) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(6284a857d0b14e06c41c41b3c49b3869).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(6284a857d0b14e06c41c41b3c49b3869) [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}
fa3da7afc66055a0c191eb95651a0198.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (9/16) (b43d98ab986093bfd5acf5614027b384) switched from RUNNING
to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(ed04b52fdbaf2a2fd05f57fc3ccfd3d5) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (9/16)
(b43d98ab986093bfd5acf5614027b384).
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16)
(b43d98ab986093bfd5acf5614027b384) [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
a4b198fb95600d832ca46261b0939a37.
[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}
c44c01bd20bd99d5aaa5279d2b3fc687.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)
(6229c9e6cffc640764f9cd13841b9528) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(27b050d2b5b5df72e2a47cafc58d6fe0) 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}
6284a857d0b14e06c41c41b3c49b3869.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (cf2f052ce1a3820bb5a02eff7adf157c) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (5/16)
(cf2f052ce1a3820bb5a02eff7adf157c).
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16)
(cf2f052ce1a3820bb5a02eff7adf157c) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(0b05e20f1f94a34aae05086f97fbe0fa) 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
b43d98ab986093bfd5acf5614027b384.
[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
cf2f052ce1a3820bb5a02eff7adf157c.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (c6880887c150a0b6292350579b07a00e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16)
(fa3da7afc66055a0c191eb95651a0198) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (a4b198fb95600d832ca46261b0939a37) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)
(c44c01bd20bd99d5aaa5279d2b3fc687) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(6284a857d0b14e06c41c41b3c49b3869) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16)
(b43d98ab986093bfd5acf5614027b384) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(cf2f052ce1a3820bb5a02eff7adf157c) 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)
(9809fc185fd8290e35280f6707ca8e86) 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)
(9809fc185fd8290e35280f6707ca8e86).
[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)
(9809fc185fd8290e35280f6707ca8e86) [FINISHED]
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (510f18575e1d313cfc38acee222301f4) 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}
9809fc185fd8290e35280f6707ca8e86.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(510f18575e1d313cfc38acee222301f4).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(510f18575e1d313cfc38acee222301f4) [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
510f18575e1d313cfc38acee222301f4.
[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)
(9809fc185fd8290e35280f6707ca8e86) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(510f18575e1d313cfc38acee222301f4) 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)
(f10aa0068ac9e438465504360bb617ca) 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)
(4d4536362ff02df3ef2b436d9dcdc460) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(211b8d0b2810e28adfb18f5a712012b5) 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)
(f10aa0068ac9e438465504360bb617ca).
[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)
(211b8d0b2810e28adfb18f5a712012b5).
[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)
(e0ce05562f80faf21b88c005e42ac001) 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)
(f10aa0068ac9e438465504360bb617ca) [FINISHED]
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(211b8d0b2810e28adfb18f5a712012b5) [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)
(4d4536362ff02df3ef2b436d9dcdc460).
[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)
(e0ce05562f80faf21b88c005e42ac001).
[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}
f10aa0068ac9e438465504360bb617ca.
[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)
(4d4536362ff02df3ef2b436d9dcdc460) [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)
(de3e619bdb0f980be753fd4ff988e631) 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 - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(e0ce05562f80faf21b88c005e42ac001) [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)
(de3e619bdb0f980be753fd4ff988e631).
[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)
(de3e619bdb0f980be753fd4ff988e631) [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)
(2c93f8c15403056a5a3778742fda09c5) 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)
(2c93f8c15403056a5a3778742fda09c5).
[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)
(2c93f8c15403056a5a3778742fda09c5) [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)
(7aaefc902e267d424787b8d9cfc9afc7) 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)
(7aaefc902e267d424787b8d9cfc9afc7).
[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)
(7aaefc902e267d424787b8d9cfc9afc7) [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)
(a47ea61cdb0baf9f8279f2eb6eb230f9) 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}
211b8d0b2810e28adfb18f5a712012b5.
[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)
(a47ea61cdb0baf9f8279f2eb6eb230f9).
[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)
(a47ea61cdb0baf9f8279f2eb6eb230f9) [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}
4d4536362ff02df3ef2b436d9dcdc460.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(f10aa0068ac9e438465504360bb617ca) 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)
(baccf1c975a50d144380c582a55e3a35) 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)
(baccf1c975a50d144380c582a55e3a35).
[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}
e0ce05562f80faf21b88c005e42ac001.
[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)
(baccf1c975a50d144380c582a55e3a35) [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)
(6344f83201928da1a7ebde9022bff726) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(649a22582ace7f16ba89de2150c80eb6) 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)
(649a22582ace7f16ba89de2150c80eb6).
[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)
(6344f83201928da1a7ebde9022bff726).
[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)
(965ef3791ecec7919872052537354196) 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)
(965ef3791ecec7919872052537354196).
[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)
(649a22582ace7f16ba89de2150c80eb6) [FINISHED]
[PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(6344f83201928da1a7ebde9022bff726) [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)
(965ef3791ecec7919872052537354196) [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}
de3e619bdb0f980be753fd4ff988e631.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(211b8d0b2810e28adfb18f5a712012b5) 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}
2c93f8c15403056a5a3778742fda09c5.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(4d4536362ff02df3ef2b436d9dcdc460) 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}
7aaefc902e267d424787b8d9cfc9afc7.
[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}
a47ea61cdb0baf9f8279f2eb6eb230f9.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(e0ce05562f80faf21b88c005e42ac001) 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}
baccf1c975a50d144380c582a55e3a35.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(de3e619bdb0f980be753fd4ff988e631) 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}
649a22582ace7f16ba89de2150c80eb6.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(2c93f8c15403056a5a3778742fda09c5) 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}
6344f83201928da1a7ebde9022bff726.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(7aaefc902e267d424787b8d9cfc9afc7) 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}
965ef3791ecec7919872052537354196.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(a47ea61cdb0baf9f8279f2eb6eb230f9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(baccf1c975a50d144380c582a55e3a35) 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)
(27c57c19cfd3378ce4455890ef906c62) 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)
(27c57c19cfd3378ce4455890ef906c62).
[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)
(27c57c19cfd3378ce4455890ef906c62) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(649a22582ace7f16ba89de2150c80eb6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
27c57c19cfd3378ce4455890ef906c62.
[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)
(3a8290b19a3b4f3d33e9b41c761d8d6d) 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)
(3a8290b19a3b4f3d33e9b41c761d8d6d).
[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)
(3a8290b19a3b4f3d33e9b41c761d8d6d) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(6344f83201928da1a7ebde9022bff726) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
3a8290b19a3b4f3d33e9b41c761d8d6d.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(965ef3791ecec7919872052537354196) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(27c57c19cfd3378ce4455890ef906c62) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(3a8290b19a3b4f3d33e9b41c761d8d6d) 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)
(aa21fd10b4cc07220a99f1fdebd88853) 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)
(aa21fd10b4cc07220a99f1fdebd88853).
[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)
(aa21fd10b4cc07220a99f1fdebd88853) [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}
aa21fd10b4cc07220a99f1fdebd88853.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$132/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(aa21fd10b4cc07220a99f1fdebd88853) 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)
(f8036ac92f8b8d6b72061ec6f5a8129e) 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)
(f8036ac92f8b8d6b72061ec6f5a8129e).
[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)
(f8036ac92f8b8d6b72061ec6f5a8129e) [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}
f8036ac92f8b8d6b72061ec6f5a8129e.
[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)
(f8036ac92f8b8d6b72061ec6f5a8129e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1218013325-c3c42293
(fba015b0b0e3096194d56e506b5c0045) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job fba015b0b0e3096194d56e506b5c0045.
[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
fba015b0b0e3096194d56e506b5c0045 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-1218013325-c3c42293(fba015b0b0e3096194d56e506b5c0045).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job fba015b0b0e3096194d56e506b5c0045.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
6d62fbe4b2412351850109d1703f0ba1: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager 9888d66603b96a4646fdd6dc35f04f9d@akka://flink/user/jobmanager_231
for job fba015b0b0e3096194d56e506b5c0045 from the resource manager.
[flink-akka.actor.default-dispatcher-4] 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-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/dispatcherbfed8a2f-678d-46e6-b57e-86b2eb352d96.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherbfed8a2f-678d-46e6-b57e-86b2eb352d96.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
fba015b0b0e3096194d56e506b5c0045 with leader id
9888d66603b96a4646fdd6dc35f04f9d lost leadership.
[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{8419cc7f3dbb2b087e672420f95d91b7}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[flink-akka.actor.default-dispatcher-6] 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{cde34c33c4643ffb9a08bb3a688fe040}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{fa25d4f3762e0c6a5e193e81c23a2de6}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{a5b16cb758b74ccf4b7cbd9a4f7174a7}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{cd1d0faf3dfd68aa0af6495492adccf2}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{42b0e3b4b253acb742c165e9da5e3715}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{444aeec36245e91ddb5bc05ef7b633c4}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{dec6463cdfa3244eb2dacca2d40c0ad3}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{8a5f9248b7bd1a24ab8a6a4a303d42cf}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{6ded434ee58d0f7c120d76ccd74b7aaf}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{931c00ef67d47fd284f6e918be16237b}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{3a858c6147b72c964daa54c3e984e49b}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{f0467a29dc3e748a054ca91741485b85}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{f4bac4022d5805bc6243b3d9ff20493a}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[flink-akka.actor.default-dispatcher-6] 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{b315d6343dc354fb02134ac7a7a9d326}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[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{1111f2fa435bba18b7655eb2ea240be6}, jobId:
fba015b0b0e3096194d56e506b5c0045).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
fba015b0b0e3096194d56e506b5c0045 from job leader monitoring.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job fba015b0b0e3096194d56e506b5c0045.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_230.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-e6a6ed84-22ea-4ef4-bfae-756c362be2c1
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherbfed8a2f-678d-46e6-b57e-86b2eb352d96.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_230.
[ForkJoinPool.commonPool-worker-13] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-13] 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:43493
[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 10166 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@6b9def24
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1218013325-c3c42293_d8b60167-4d86-4a5e-9b74-888aec62b15c/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-1218013325-c3c42293_d8b60167-4d86-4a5e-9b74-888aec62b15c/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:33193
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:39579
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 4 failed, 2 skipped
Finished generating test XML results (1.504 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.973 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[Daemon worker,5,main]) completed. Took 39 mins 8.167 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 42m 14s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/ku64xelwghoxu
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]
