See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/124/display/redirect?page=changes>
Changes:
[lcwik] [BEAM-6194] Follow up with cleanup for
------------------------------------------
[...truncated 232.27 MB...]
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (1/16)
(8cf84a13d7b180a1af4260474a8b374c).
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16)
(8cf84a13d7b180a1af4260474a8b374c) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
8fcad6f932f216fb71d3ea1dd711b328.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
aa10a001e42ae60756f1c874997cbbf9.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)
(e7fbc6cb5efd3f021032881093588359) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
683202bc8cf101cb2b274151a113711a.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
1a1a2dba98c672b56c737129296ce52c.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
8cf84a13d7b180a1af4260474a8b374c.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(f6a8c93c8c141cca218aa17cf1161648) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)
(41217e22fd63bd61152c87b7e9cc5a4d) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)
(41217e22fd63bd61152c87b7e9cc5a4d).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/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$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)
(41217e22fd63bd61152c87b7e9cc5a4d) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
41217e22fd63bd61152c87b7e9cc5a4d.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (ce9932d141c15044700d1497b9606c41) switched from RUNNING
to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (937e1b745747dc66d71ce1bb816779de) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (5/16)
(ce9932d141c15044700d1497b9606c41).
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16)
(ce9932d141c15044700d1497b9606c41) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(52a3481f8f52110494457938f9a46a01) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
ce9932d141c15044700d1497b9606c41.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(9a27a5bc7b009c46b78815ee34bce0f0) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(ada48208871c2bd00380cd37e6105850) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(ada48208871c2bd00380cd37e6105850).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(ada48208871c2bd00380cd37e6105850) [FINISHED]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (6/16) (d51eb5264ec804c9ceda7df589f5c76f) 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$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
ada48208871c2bd00380cd37e6105850.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)
(ac9356f1b77510eeb3f51b694cdb4fa0) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (6/16)
(d51eb5264ec804c9ceda7df589f5c76f).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (7254951b53e4f69d8dde92ca8b00e7b0) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)
(ac9356f1b77510eeb3f51b694cdb4fa0).
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16)
(d51eb5264ec804c9ceda7df589f5c76f) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)
(ac9356f1b77510eeb3f51b694cdb4fa0) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
d51eb5264ec804c9ceda7df589f5c76f.
[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$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
ac9356f1b77510eeb3f51b694cdb4fa0.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(49382117f8b90af80abf9a582c37e908) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (4/16) (6fcde226f590ba6e04608f74936ce4b3) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (14/16) (55d4ec7216e6534a1300e3e96d535ba0) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (14/16)
(55d4ec7216e6534a1300e3e96d535ba0).
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (4/16)
(6fcde226f590ba6e04608f74936ce4b3).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (a9c6494a442f9bb6522dbf2b4a5b2e2b) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16)
(55d4ec7216e6534a1300e3e96d535ba0) [FINISHED]
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16)
(6fcde226f590ba6e04608f74936ce4b3) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
55d4ec7216e6534a1300e3e96d535ba0.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
6fcde226f590ba6e04608f74936ce4b3.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)
(d9671eaa8f087dc8a3bb2cf27a988893) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (8fcad6f932f216fb71d3ea1dd711b328) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (aa10a001e42ae60756f1c874997cbbf9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(683202bc8cf101cb2b274151a113711a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16)
(1a1a2dba98c672b56c737129296ce52c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16)
(8cf84a13d7b180a1af4260474a8b374c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)
(41217e22fd63bd61152c87b7e9cc5a4d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(ce9932d141c15044700d1497b9606c41) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(ada48208871c2bd00380cd37e6105850) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(76fa10a5a347dec806a13e33b88a8ef7) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(76fa10a5a347dec806a13e33b88a8ef7).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(d51eb5264ec804c9ceda7df589f5c76f) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/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$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(76fa10a5a347dec806a13e33b88a8ef7) [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$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
76fa10a5a347dec806a13e33b88a8ef7.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)
(ac9356f1b77510eeb3f51b694cdb4fa0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (55d4ec7216e6534a1300e3e96d535ba0) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (7/16) (620fa46414bdbbd5582694e77374d0ba) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (7/16)
(620fa46414bdbbd5582694e77374d0ba).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16)
(6fcde226f590ba6e04608f74936ce4b3) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16)
(620fa46414bdbbd5582694e77374d0ba) [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
620fa46414bdbbd5582694e77374d0ba.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(76fa10a5a347dec806a13e33b88a8ef7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(620fa46414bdbbd5582694e77374d0ba) switched from RUNNING to FINISHED.
[grpc-default-executor-185] WARN
org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not
supported in the current execution environment.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(76e1ded70c7d36da886fdbefbb9fbedf) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(76e1ded70c7d36da886fdbefbb9fbedf).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/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$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(76e1ded70c7d36da886fdbefbb9fbedf) [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$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
76e1ded70c7d36da886fdbefbb9fbedf.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (b74f0f763f5c274ad3634dc31d6ac87a) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(b74f0f763f5c274ad3634dc31d6ac87a).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(b74f0f763f5c274ad3634dc31d6ac87a) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
b74f0f763f5c274ad3634dc31d6ac87a.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(76e1ded70c7d36da886fdbefbb9fbedf) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(b74f0f763f5c274ad3634dc31d6ac87a) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(0c1bdced27a99e30d3e597e8f6d09320) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(0c1bdced27a99e30d3e597e8f6d09320).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(0c1bdced27a99e30d3e597e8f6d09320) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(0d3d0cb85e44f1c9174dc570ed5d566c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(0d3d0cb85e44f1c9174dc570ed5d566c).
[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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
0c1bdced27a99e30d3e597e8f6d09320.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(0d3d0cb85e44f1c9174dc570ed5d566c) [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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
0d3d0cb85e44f1c9174dc570ed5d566c.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(0c1bdced27a99e30d3e597e8f6d09320) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(0d3d0cb85e44f1c9174dc570ed5d566c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(cbf4351858217b87e244675182960c22) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(cbf4351858217b87e244675182960c22).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(cbf4351858217b87e244675182960c22) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(523fbcc43182e8a2b9ad1aa05cb7b00d) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(523fbcc43182e8a2b9ad1aa05cb7b00d).
[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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
cbf4351858217b87e244675182960c22.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(a862c2d4e4a0e4c0a654f3abbe1e2e16) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(523fbcc43182e8a2b9ad1aa05cb7b00d) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(a862c2d4e4a0e4c0a654f3abbe1e2e16).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(a862c2d4e4a0e4c0a654f3abbe1e2e16) [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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
523fbcc43182e8a2b9ad1aa05cb7b00d.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(68a835602a37a64c4add14ca78cb4622) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(68a835602a37a64c4add14ca78cb4622).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(68a835602a37a64c4add14ca78cb4622) [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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
a862c2d4e4a0e4c0a654f3abbe1e2e16.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(cbf4351858217b87e244675182960c22) 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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
68a835602a37a64c4add14ca78cb4622.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(523fbcc43182e8a2b9ad1aa05cb7b00d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(a862c2d4e4a0e4c0a654f3abbe1e2e16) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(c2fb7bcd17492699fb324608d92557a0) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(c2fb7bcd17492699fb324608d92557a0).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(c2fb7bcd17492699fb324608d92557a0) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(339169e300a997f54281afd1067b25d3) 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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
c2fb7bcd17492699fb324608d92557a0.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(339169e300a997f54281afd1067b25d3).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(339169e300a997f54281afd1067b25d3) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(ab16bfb00477c70313f9ac4eae776662) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(aecbe4661f980cf643b97949340e630a) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(ab16bfb00477c70313f9ac4eae776662).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(aecbe4661f980cf643b97949340e630a).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(ab16bfb00477c70313f9ac4eae776662) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(aecbe4661f980cf643b97949340e630a) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(68a835602a37a64c4add14ca78cb4622) 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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
339169e300a997f54281afd1067b25d3.
[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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
ab16bfb00477c70313f9ac4eae776662.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(c2fb7bcd17492699fb324608d92557a0) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(bbed32a7e23cc2154ad222f0f5564698) 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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
aecbe4661f980cf643b97949340e630a.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(bbed32a7e23cc2154ad222f0f5564698).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(bbed32a7e23cc2154ad222f0f5564698) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(a11866483a42a81e34a517e0fe6c48ab) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(a11866483a42a81e34a517e0fe6c48ab).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(a11866483a42a81e34a517e0fe6c48ab) [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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
bbed32a7e23cc2154ad222f0f5564698.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(339169e300a997f54281afd1067b25d3) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(42015cd6f67bbffe71e0921f8af3a501) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(42015cd6f67bbffe71e0921f8af3a501).
[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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
a11866483a42a81e34a517e0fe6c48ab.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(42015cd6f67bbffe71e0921f8af3a501) [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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
42015cd6f67bbffe71e0921f8af3a501.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(ab16bfb00477c70313f9ac4eae776662) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(aecbe4661f980cf643b97949340e630a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(bbed32a7e23cc2154ad222f0f5564698) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(a11866483a42a81e34a517e0fe6c48ab) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(569179d5a2a92a151c77fcbcf254f830) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(59edbf119ebfa804b4893842aabdee51) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(569179d5a2a92a151c77fcbcf254f830).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(59edbf119ebfa804b4893842aabdee51).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(569179d5a2a92a151c77fcbcf254f830) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(59edbf119ebfa804b4893842aabdee51) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
59edbf119ebfa804b4893842aabdee51.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(42015cd6f67bbffe71e0921f8af3a501) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
569179d5a2a92a151c77fcbcf254f830.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(59edbf119ebfa804b4893842aabdee51) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(569179d5a2a92a151c77fcbcf254f830) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(eeaa0adf486d98dcda07faf8b9bebfeb) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(eeaa0adf486d98dcda07faf8b9bebfeb).
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(eeaa0adf486d98dcda07faf8b9bebfeb) [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$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
eeaa0adf486d98dcda07faf8b9bebfeb.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(eeaa0adf486d98dcda07faf8b9bebfeb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1207202645-1f5b823a
(5ae3b43c81b941db630a50e0f37bbe3f) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job 5ae3b43c81b941db630a50e0f37bbe3f.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
5ae3b43c81b941db630a50e0f37bbe3f reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1207202645-1f5b823a(5ae3b43c81b941db630a50e0f37bbe3f).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 5ae3b43c81b941db630a50e0f37bbe3f.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
8ec5a47fa42639ca1a559e2d0b56a953: JobManager is shutting down..
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager 82d6c1636f1f73566036c60397974851@akka://flink/user/jobmanager_261
for job 5ae3b43c81b941db630a50e0f37bbe3f from the resource manager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher14fe6c93-368e-443c-b369-0ed7fa342034.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher14fe6c93-368e-443c-b369-0ed7fa342034.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
5ae3b43c81b941db630a50e0f37bbe3f with leader id
82d6c1636f1f73566036c60397974851 lost leadership.
[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{7d1f27ba4e49f47810c83bebe7981c3c}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{0c8c9dbfde6e54c1f779ad22da5b8648}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{db42ca0a5a45249471772d2255f38fb5}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{d2c03b6229c6cfc06d873247b463057a}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{f7f4bf94821e3babcb2b58a3f131c190}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{4eeb52982afacca11e5590d2b5d381e5}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{8cccc8d358c16d9295093a1f8dcd0306}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{8ff07de580372b137acfe847bf92bf08}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{6ef66b458fab8474621f532a4dbd5444}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{68786c6ea9b7c457c63ca9711b7da091}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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-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{b73622996fe25eeb557e3230829f9da7}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{a41d46eea160ded603437d16acaa1249}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher14fe6c93-368e-443c-b369-0ed7fa342034.
[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{a99e64dc2ce13465b479f7e808027c5d}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{efa410ecb1f5e534b5375dfdb22baa28}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{3286b1d21114e6e413735b59246debd1}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[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{8c1f32cb6819e578e51f9e24f4079b75}, jobId:
5ae3b43c81b941db630a50e0f37bbe3f).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
5ae3b43c81b941db630a50e0f37bbe3f from job leader monitoring.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job 5ae3b43c81b941db630a50e0f37bbe3f.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[ForkJoinPool.commonPool-worker-2] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-bcaa283e-b7e3-4b5a-a941-d85c2e15840a
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41955
[flink-akka.actor.default-dispatcher-4] 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 8086 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@7c887f05
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1207202645-1f5b823a_19b7ce4e-f426-470d-b871-b4b03d180a08/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-1207202645-1f5b823a_19b7ce4e-f426-470d-b871-b4b03d180a08/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:33533
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:45559
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.75 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 (1.013 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 2,5,main]) completed. Took 43 mins 50.135
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 46m 27s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/zaptd6za2fwy6
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]
