See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/143/display/redirect?page=changes>
Changes:
[huangry] Add instructions to post-commit policy web page, according to
[huangry] Update website/src/contribute/postcommits-policies-details.md
------------------------------------------
[...truncated 234.19 MB...]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(536d5e2870e1c484542647c92da1b393) 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
8d3011cf67d64562184d50d699f9c2e1.
[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
c6a026c7449b8b147a3638a9e8ffe528.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16)
(fb79b800ef0e117e5f3fc2d1b67781ea) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (5cbbf3c7dc78e1a3244eb8ccf9fc4b30) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (8/16) (98f5db8ce1e857164a89dc595ee8a97f) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (8/16)
(98f5db8ce1e857164a89dc595ee8a97f).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (14/16) (b82c375e0950515c8eae05c654715f5b) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (14/16)
(b82c375e0950515c8eae05c654715f5b).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)
(ae8307e1a1d89483230786663e4b89e4) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16)
(98f5db8ce1e857164a89dc595ee8a97f) [FINISHED]
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16)
(b82c375e0950515c8eae05c654715f5b) [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
98f5db8ce1e857164a89dc595ee8a97f.
[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
b82c375e0950515c8eae05c654715f5b.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(c6c361646726e5759dd625f0f6553109) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16)
(76d58a1bed7178206410c857ee817d1e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(3854f7e3cca265999b41aac7615a6fde) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)
(8def7d840f987368ceeb8ff08dd90602) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/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} (16/16)
(8def7d840f987368ceeb8ff08dd90602).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)
(8def7d840f987368ceeb8ff08dd90602) [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}
8def7d840f987368ceeb8ff08dd90602.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(827a48fb89b66fdbbc5cff4b64f4025b) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/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} (12/16)
(827a48fb89b66fdbbc5cff4b64f4025b).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(b600fa7579615d084176de64e85179ea) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/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} (13/16)
(b600fa7579615d084176de64e85179ea).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(827a48fb89b66fdbbc5cff4b64f4025b) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(b600fa7579615d084176de64e85179ea) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(021cfd1fbd95a69b3887e3703ddd3794) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16)
(ece389fdb5e6a198453a75ec2263434a) 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}
827a48fb89b66fdbbc5cff4b64f4025b.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/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} (15/16)
(ece389fdb5e6a198453a75ec2263434a).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/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$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16)
(ece389fdb5e6a198453a75ec2263434a) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(8d3011cf67d64562184d50d699f9c2e1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (c6a026c7449b8b147a3638a9e8ffe528) 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}
b600fa7579615d084176de64e85179ea.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(98f5db8ce1e857164a89dc595ee8a97f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (b82c375e0950515c8eae05c654715f5b) 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}
ece389fdb5e6a198453a75ec2263434a.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (544a29e32c8abf69b04cca83a7ceca87) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (16/16)
(544a29e32c8abf69b04cca83a7ceca87).
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16)
(544a29e32c8abf69b04cca83a7ceca87) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)
(8def7d840f987368ceeb8ff08dd90602) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (90aa61ffd6e8dac2729492c1b5e3e713) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(90aa61ffd6e8dac2729492c1b5e3e713).
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (12/16) (93f56d12768c71f5bc14721db2e473bc) 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
544a29e32c8abf69b04cca83a7ceca87.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (12/16)
(93f56d12768c71f5bc14721db2e473bc).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16)
(90aa61ffd6e8dac2729492c1b5e3e713) [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
90aa61ffd6e8dac2729492c1b5e3e713.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16)
(93f56d12768c71f5bc14721db2e473bc) [FINISHED]
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (15/16) (8f6f8feda878b1869fcf126a6dc5a945) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (15/16)
(8f6f8feda878b1869fcf126a6dc5a945).
[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
93f56d12768c71f5bc14721db2e473bc.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16)
(8f6f8feda878b1869fcf126a6dc5a945) [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
8f6f8feda878b1869fcf126a6dc5a945.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)
(827a48fb89b66fdbbc5cff4b64f4025b) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(5cbbf3c7dc78e1a3244eb8ccf9fc4b30).
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(5cbbf3c7dc78e1a3244eb8ccf9fc4b30) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
5cbbf3c7dc78e1a3244eb8ccf9fc4b30.
[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} (13/16)
(b600fa7579615d084176de64e85179ea) switched from RUNNING to FINISHED.
[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} (15/16)
(ece389fdb5e6a198453a75ec2263434a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (544a29e32c8abf69b04cca83a7ceca87) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (90aa61ffd6e8dac2729492c1b5e3e713) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (93f56d12768c71f5bc14721db2e473bc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (8f6f8feda878b1869fcf126a6dc5a945) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (5cbbf3c7dc78e1a3244eb8ccf9fc4b30) switched from RUNNING to FINISHED.
[grpc-default-executor-137] 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)
(43fce78ea52b94dfe21a29f4c873788c) 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)
(43fce78ea52b94dfe21a29f4c873788c).
[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)
(43fce78ea52b94dfe21a29f4c873788c) [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}
43fce78ea52b94dfe21a29f4c873788c.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (6ed4765f9ff71a9cd7c0b7fd76e74714) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(6ed4765f9ff71a9cd7c0b7fd76e74714).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(6ed4765f9ff71a9cd7c0b7fd76e74714) [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
6ed4765f9ff71a9cd7c0b7fd76e74714.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(43fce78ea52b94dfe21a29f4c873788c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(6ed4765f9ff71a9cd7c0b7fd76e74714) 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)
(7aa244f5f9fce25a5c6d39b0e57c9e5a) 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 - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(7aa244f5f9fce25a5c6d39b0e57c9e5a).
[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)
(7aa244f5f9fce25a5c6d39b0e57c9e5a) [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)
(4d29cff6b166291b6d3ec810aaad6678) 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)
(4d29cff6b166291b6d3ec810aaad6678).
[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}
7aa244f5f9fce25a5c6d39b0e57c9e5a.
[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)
(4d29cff6b166291b6d3ec810aaad6678) [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}
4d29cff6b166291b6d3ec810aaad6678.
[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)
(2e430e8ab181be7dfe23469b01cbb4c8) 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)
(47e2e8221c661702cb50c69ff7de3496) 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)
(2e430e8ab181be7dfe23469b01cbb4c8).
[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)
(47e2e8221c661702cb50c69ff7de3496).
[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)
(2e430e8ab181be7dfe23469b01cbb4c8) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(7aa244f5f9fce25a5c6d39b0e57c9e5a) 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 -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(bb36b23dcb81e351b857291337a35137) 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 - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(47e2e8221c661702cb50c69ff7de3496) [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)
(bb36b23dcb81e351b857291337a35137).
[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)
(bb36b23dcb81e351b857291337a35137) [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)
(be2848a92a1974f969bfe072bafaf2a9) 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}
2e430e8ab181be7dfe23469b01cbb4c8.
[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)
(be2848a92a1974f969bfe072bafaf2a9).
[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)
(be2848a92a1974f969bfe072bafaf2a9) [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}
47e2e8221c661702cb50c69ff7de3496.
[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)
(0797f1662ad1cc47b486ddb8c602df43) switched from RUNNING to FINISHED.
[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)
(0797f1662ad1cc47b486ddb8c602df43).
[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)
(0797f1662ad1cc47b486ddb8c602df43) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(4d29cff6b166291b6d3ec810aaad6678) 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}
bb36b23dcb81e351b857291337a35137.
[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}
be2848a92a1974f969bfe072bafaf2a9.
[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)
(229d108e23408e87aa16a928bbbcde75) 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}
0797f1662ad1cc47b486ddb8c602df43.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)
(2e430e8ab181be7dfe23469b01cbb4c8) 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)
(229d108e23408e87aa16a928bbbcde75).
[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)
(229d108e23408e87aa16a928bbbcde75) [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}
229d108e23408e87aa16a928bbbcde75.
[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)
(022a77938da59adf9e81ed5f3e23b9d2) 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)
(022a77938da59adf9e81ed5f3e23b9d2).
[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)
(022a77938da59adf9e81ed5f3e23b9d2) [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}
022a77938da59adf9e81ed5f3e23b9d2.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)
(47e2e8221c661702cb50c69ff7de3496) 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 -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(0c06947565d8daf3bfd046f6f2bc3def) 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)
(0c06947565d8daf3bfd046f6f2bc3def).
[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)
(0c06947565d8daf3bfd046f6f2bc3def) [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)
(c2c9467db99e85530175d9188b561127) 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}
0c06947565d8daf3bfd046f6f2bc3def.
[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)
(c2c9467db99e85530175d9188b561127).
[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)
(c2c9467db99e85530175d9188b561127) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(bb36b23dcb81e351b857291337a35137) 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}
c2c9467db99e85530175d9188b561127.
[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)
(6235a707148b832bb68fabca2f9a7f58) 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 - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(6235a707148b832bb68fabca2f9a7f58).
[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)
(6235a707148b832bb68fabca2f9a7f58) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(be2848a92a1974f969bfe072bafaf2a9) 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}
6235a707148b832bb68fabca2f9a7f58.
[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)
(78c5e4dbdeaeea5470451befd2d301bc) 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)
(ed675965aa4950112d7248fc8dd49e59) 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)
(ed675965aa4950112d7248fc8dd49e59).
[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)
(78c5e4dbdeaeea5470451befd2d301bc).
[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)
(ed675965aa4950112d7248fc8dd49e59) [FINISHED]
[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)
(78c5e4dbdeaeea5470451befd2d301bc) [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}
78c5e4dbdeaeea5470451befd2d301bc.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(0797f1662ad1cc47b486ddb8c602df43) 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}
ed675965aa4950112d7248fc8dd49e59.
[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)
(0dac740acba02c2ecdda42d411e634eb) 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)
(0dac740acba02c2ecdda42d411e634eb).
[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)
(0dac740acba02c2ecdda42d411e634eb) [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}
0dac740acba02c2ecdda42d411e634eb.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(229d108e23408e87aa16a928bbbcde75) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(022a77938da59adf9e81ed5f3e23b9d2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(0c06947565d8daf3bfd046f6f2bc3def) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(c2c9467db99e85530175d9188b561127) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(6235a707148b832bb68fabca2f9a7f58) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(78c5e4dbdeaeea5470451befd2d301bc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(ed675965aa4950112d7248fc8dd49e59) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(0dac740acba02c2ecdda42d411e634eb) 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)
(e561531523c501edd1c94053df6481f9) 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)
(e561531523c501edd1c94053df6481f9).
[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)
(e561531523c501edd1c94053df6481f9) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
e561531523c501edd1c94053df6481f9.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(e561531523c501edd1c94053df6481f9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1210135845-6af80217
(db3432eb57cee300a91bbaaf9d361442) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job db3432eb57cee300a91bbaaf9d361442.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
db3432eb57cee300a91bbaaf9d361442 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1210135845-6af80217(db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
feaea1bec19a8dfe4982916493f99d5b: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job db3432eb57cee300a91bbaaf9d361442.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager afab43569901d7d02013cfeb6f6b466c@akka://flink/user/jobmanager_261
for job db3432eb57cee300a91bbaaf9d361442 from the resource manager.
[flink-akka.actor.default-dispatcher-3] 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-3] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher9bb888f7-d98e-4771-9626-e8706217f3ff.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher9bb888f7-d98e-4771-9626-e8706217f3ff.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
db3432eb57cee300a91bbaaf9d361442 with leader id
afab43569901d7d02013cfeb6f6b466c lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-2] 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{1e2f169d477b05a302cf363235137943}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{3e0de8ef852488714b4d3552378cf8a8}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{29381caa2a792b3d19e50034eccf21be}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{a2b11e3b26b3837ec6dace0c66cd9199}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-2] 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{086de5a8c3a4fd85ab126701863fe466}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher9bb888f7-d98e-4771-9626-e8706217f3ff.
[flink-akka.actor.default-dispatcher-2] 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{5742b733ff9e7da9676183ceb533367c}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{fccaca676bfb7b2d9f0ac287c0ff7863}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{b3492c593e133436405ef47cd500f5f9}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{98a16151bb074cef61d9189393d99d84}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{c20c23c2ecc4261fff58a62f2fa60a64}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{aa656a9ebff8e51829cdeb37e305aa48}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{6440d006c3d14090bdbcfaff8664a289}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{81ca2adb2b14948fed6941ade4e3f269}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-2] 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{b88adadfc62a199e7c06e2f8ccc980b6}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-4] 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{50ee9ace28cc61362cb7479eaebbc028}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{4d654a282b110d367e8ac07f5fbac198}, jobId:
db3432eb57cee300a91bbaaf9d361442).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
db3432eb57cee300a91bbaaf9d361442 from job leader monitoring.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job db3432eb57cee300a91bbaaf9d361442.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-4b909906-219b-467c-9900-03e09fd929bf
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_260.
[ForkJoinPool.commonPool-worker-2] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-2] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:43869
[flink-akka.actor.default-dispatcher-6] 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 7407 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@a20d4631
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1210135845-6af80217_7d7e5dce-c2b9-4aea-97db-8727f4ea986d/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-1210135845-6af80217_7d7e5dce-c2b9-4aea-97db-8727f4ea986d/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:46115
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:37435
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 3 failed, 2 skipped
Finished generating test XML results (1.481 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.98 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 41 mins 31.159 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 43m 48s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/ddck26mlkqa4u
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]