See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/121/display/redirect?page=changes>
Changes:
[ankurgoenka] [BEAM-5167] Log unscheduled process bundle requrests
------------------------------------------
[...truncated 235.77 MB...]
[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
f158944f3b23731270ee3c855e0bde83.
[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
f8336a3dfee1e3b595ae33aa6d415df5.
[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}
3302a691abaee3c01f9d7fa383c2ead5.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (14155c4457acc0fd933530a25ff29922) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(14155c4457acc0fd933530a25ff29922).
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (5/16) (63415952937097ba0904487e35fad956) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (5/16)
(63415952937097ba0904487e35fad956).
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(14155c4457acc0fd933530a25ff29922) [FINISHED]
[ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16)
(63415952937097ba0904487e35fad956) [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}
3e5b0b3fdd2c08772adf619372aeffc0.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (4/16) (86dccb1f6b80e694b32a39a270e510ec) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (4/16)
(86dccb1f6b80e694b32a39a270e510ec).
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16)
(86dccb1f6b80e694b32a39a270e510ec) [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
e417b23c3ddecfaa3351f56f114ea604.
[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
7c658e504c0b16bb117355e9a7cc172d.
[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}
ac18df9d8538721a24a1882697c7bbc9.
[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)
(cbac800eb9418cd6eb0b171f807c843f) 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)
(cbac800eb9418cd6eb0b171f807c843f).
[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)
(cbac800eb9418cd6eb0b171f807c843f) [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
2c409d6fedcc7ddb7b9e477bd7dbd6ea.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)
(8047aac53fb27a9a8a1c5ccdd5c8eeaa) 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}
d29ce9b8f7090367dd0a6ccc9e90f5a3.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/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} (11/16)
(8047aac53fb27a9a8a1c5ccdd5c8eeaa).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)
(8047aac53fb27a9a8a1c5ccdd5c8eeaa) [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
14155c4457acc0fd933530a25ff29922.
[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
63415952937097ba0904487e35fad956.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)
(0a7ff35a38f46b455a4c57976d9878db) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/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} (9/16)
(0a7ff35a38f46b455a4c57976d9878db).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)
(0a7ff35a38f46b455a4c57976d9878db) [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
86dccb1f6b80e694b32a39a270e510ec.
[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}
cbac800eb9418cd6eb0b171f807c843f.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (11/16) (0165a464c053eddc73c007d7ada0947d) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (11/16)
(0165a464c053eddc73c007d7ada0947d).
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (12/16) (1ac32542163a8ae4db52e1693ab209e2) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (12/16)
(1ac32542163a8ae4db52e1693ab209e2).
[ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16)
(0165a464c053eddc73c007d7ada0947d) [FINISHED]
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16)
(1ac32542163a8ae4db52e1693ab209e2) [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}
8047aac53fb27a9a8a1c5ccdd5c8eeaa.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (9/16) (ba5ff27555d6c5ea009716965cc4e595) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (9/16)
(ba5ff27555d6c5ea009716965cc4e595).
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16)
(ba5ff27555d6c5ea009716965cc4e595) [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}
0a7ff35a38f46b455a4c57976d9878db.
[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
0165a464c053eddc73c007d7ada0947d.
[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
1ac32542163a8ae4db52e1693ab209e2.
[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
ba5ff27555d6c5ea009716965cc4e595.
[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} (8/16)
(482b87a6120175685e21e936fc0adb39) 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} (10/16)
(a95619c1846bbe49ba43c47010d8a3b3) 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} (16/16)
(b77473236a95e90e95e1b969ef7c3bc2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16)
(f158944f3b23731270ee3c855e0bde83) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (f8336a3dfee1e3b595ae33aa6d415df5) 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} (6/16)
(3302a691abaee3c01f9d7fa383c2ead5) 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)
(3e5b0b3fdd2c08772adf619372aeffc0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16)
(e417b23c3ddecfaa3351f56f114ea604) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16)
(7c658e504c0b16bb117355e9a7cc172d) 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} (4/16)
(ac18df9d8538721a24a1882697c7bbc9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (2c409d6fedcc7ddb7b9e477bd7dbd6ea) 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} (5/16)
(d29ce9b8f7090367dd0a6ccc9e90f5a3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (14155c4457acc0fd933530a25ff29922) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(63415952937097ba0904487e35fad956) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16)
(86dccb1f6b80e694b32a39a270e510ec) 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} (12/16)
(cbac800eb9418cd6eb0b171f807c843f) 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} (11/16)
(8047aac53fb27a9a8a1c5ccdd5c8eeaa) 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} (9/16)
(0a7ff35a38f46b455a4c57976d9878db) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(11/16) (0165a464c053eddc73c007d7ada0947d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(12/16) (1ac32542163a8ae4db52e1693ab209e2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16)
(ba5ff27555d6c5ea009716965cc4e595) switched from RUNNING to FINISHED.
[grpc-default-executor-162] 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)
(e41b9820ffb2708356e1f96c94ae9098) 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)
(e41b9820ffb2708356e1f96c94ae9098).
[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)
(e41b9820ffb2708356e1f96c94ae9098) [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}
e41b9820ffb2708356e1f96c94ae9098.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (965b58526571bd845bdfc3308f2bfc68) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(965b58526571bd845bdfc3308f2bfc68).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(965b58526571bd845bdfc3308f2bfc68) [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
965b58526571bd845bdfc3308f2bfc68.
[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} (2/16)
(e41b9820ffb2708356e1f96c94ae9098) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(965b58526571bd845bdfc3308f2bfc68) 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)
(15b1ecf9a8f9dc3826a59c4f4a5998cd) 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)
(15b1ecf9a8f9dc3826a59c4f4a5998cd).
[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)
(15b1ecf9a8f9dc3826a59c4f4a5998cd) [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)
(963124f4d06cfe5fa68672433aafa844) 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)
(963124f4d06cfe5fa68672433aafa844).
[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)
(963124f4d06cfe5fa68672433aafa844) [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}
15b1ecf9a8f9dc3826a59c4f4a5998cd.
[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)
(f54f5327e896f83e491b8c733dcbe402) 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)
(f54f5327e896f83e491b8c733dcbe402).
[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)
(f54f5327e896f83e491b8c733dcbe402) [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)
(37646bdcd6632fd2a7924a7f6e8fdf6b) 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)
(8396fb8c643935d67bd50832f4491c4d) 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)
(8396fb8c643935d67bd50832f4491c4d).
[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)
(37646bdcd6632fd2a7924a7f6e8fdf6b).
[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)
(8396fb8c643935d67bd50832f4491c4d) [FINISHED]
[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)
(37646bdcd6632fd2a7924a7f6e8fdf6b) [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}
963124f4d06cfe5fa68672433aafa844.
[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)
(af5ce47122c0f0ba8f1aa3deaf029dfe) 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)
(af5ce47122c0f0ba8f1aa3deaf029dfe).
[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)
(af5ce47122c0f0ba8f1aa3deaf029dfe) [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}
f54f5327e896f83e491b8c733dcbe402.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)
(15b1ecf9a8f9dc3826a59c4f4a5998cd) 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}
8396fb8c643935d67bd50832f4491c4d.
[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)
(963124f4d06cfe5fa68672433aafa844) 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}
37646bdcd6632fd2a7924a7f6e8fdf6b.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)
(f54f5327e896f83e491b8c733dcbe402) 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}
af5ce47122c0f0ba8f1aa3deaf029dfe.
[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)
(3d7ecd5f8fda5cc1765f6a5ff4484554) switched from RUNNING to 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)
(3d7ecd5f8fda5cc1765f6a5ff4484554).
[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)
(2cd141e1155c96924cff0344fcf93c94) switched from RUNNING to 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)
(3d7ecd5f8fda5cc1765f6a5ff4484554) [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)
(2cd141e1155c96924cff0344fcf93c94).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(8396fb8c643935d67bd50832f4491c4d) 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}
3d7ecd5f8fda5cc1765f6a5ff4484554.
[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)
(2cd141e1155c96924cff0344fcf93c94) [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)
(37646bdcd6632fd2a7924a7f6e8fdf6b) 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}
2cd141e1155c96924cff0344fcf93c94.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(af5ce47122c0f0ba8f1aa3deaf029dfe) 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} (3/16)
(3d7ecd5f8fda5cc1765f6a5ff4484554) 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} (12/16)
(2cd141e1155c96924cff0344fcf93c94) 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)
(ca761cdb0bf953214c2365258b8a4783) 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 - Freeing task resources for
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(ca761cdb0bf953214c2365258b8a4783).
[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)
(ca761cdb0bf953214c2365258b8a4783) [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}
ca761cdb0bf953214c2365258b8a4783.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(ca761cdb0bf953214c2365258b8a4783) 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)
(d293c148fa4b11069fe787138f41a314) 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)
(d293c148fa4b11069fe787138f41a314).
[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)
(d293c148fa4b11069fe787138f41a314) [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)
(823c767a396b8fdd26abcc07f716bada) 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)
(823c767a396b8fdd26abcc07f716bada).
[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/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
d293c148fa4b11069fe787138f41a314.
[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)
(823c767a396b8fdd26abcc07f716bada) [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)
(2f57a3ee6d1529555bca375f4d176e30) 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)
(2f57a3ee6d1529555bca375f4d176e30).
[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)
(2f57a3ee6d1529555bca375f4d176e30) [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)
(cfe946b314177adbc5f91560356e34d1) 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)
(cfe946b314177adbc5f91560356e34d1).
[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/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
823c767a396b8fdd26abcc07f716bada.
[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)
(cfe946b314177adbc5f91560356e34d1) [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/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
2f57a3ee6d1529555bca375f4d176e30.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(d293c148fa4b11069fe787138f41a314) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
cfe946b314177adbc5f91560356e34d1.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(823c767a396b8fdd26abcc07f716bada) 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 -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(d1abbd172187450d9f4248bb66473fcc) 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)
(d1abbd172187450d9f4248bb66473fcc).
[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)
(2f57a3ee6d1529555bca375f4d176e30) 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 - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(d1abbd172187450d9f4248bb66473fcc) [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/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
d1abbd172187450d9f4248bb66473fcc.
[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)
(81233b74d1a809f198837e8c6796e1d2) 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)
(81233b74d1a809f198837e8c6796e1d2).
[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)
(81233b74d1a809f198837e8c6796e1d2) [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} (10/16)
(cfe946b314177adbc5f91560356e34d1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
81233b74d1a809f198837e8c6796e1d2.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)
(d1abbd172187450d9f4248bb66473fcc) 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} (16/16)
(81233b74d1a809f198837e8c6796e1d2) 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)
(22fb45ce79ba4fc9329bbc04cfbd9b82) 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)
(22fb45ce79ba4fc9329bbc04cfbd9b82).
[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)
(22fb45ce79ba4fc9329bbc04cfbd9b82) [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}
22fb45ce79ba4fc9329bbc04cfbd9b82.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)
(22fb45ce79ba4fc9329bbc04cfbd9b82) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1207122550-5f7d3b72
(a2008824fc98b68a08a20655ceff1343) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job a2008824fc98b68a08a20655ceff1343.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
a2008824fc98b68a08a20655ceff1343 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-1207122550-5f7d3b72(a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job a2008824fc98b68a08a20655ceff1343.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
21312f5b9a97fa4d7b82aa7ec26ad97d: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager 96dc6646583505886c24ae6553de473e@akka://flink/user/jobmanager_261
for job a2008824fc98b68a08a20655ceff1343 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-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherf31e4491-fb62-4167-a558-ea2e9b24220d.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherf31e4491-fb62-4167-a558-ea2e9b24220d.
[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-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
a2008824fc98b68a08a20655ceff1343 with leader id
96dc6646583505886c24ae6553de473e lost leadership.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{4ef4a3317a242c0ad81e00550dc20d59}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{aa7784aec58a35e9e6549f13cf7865c4}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:9, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{86e4c942e3fe9573f5f632e69560aef5}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:10, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{e85e8ef5a580dec5a98a19797a0822fa}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{423281979d8e27bedda0f9fb2eaae545}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:8, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{57c5ad8f2b2155566f7816362b7a45f3}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:12, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{96273f168019e1804a918d03a71ca12a}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:15, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{7941ba782072579efbea0c1e36d80121}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{db6bc21f0c2e8d55b7f5b71d530a33b1}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{dc8ae4d6f540b231a865de354c06c91b}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{be55f6e05f042fb243c2f353c7fe1ea2}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:13, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{c033f4403c3a8f5749a3919cf56a34de}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{bd9a63f29db5f3799d00af7cd8573a8f}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot
TaskSlot(index:14, state:ALLOCATED, resource profile:
ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0,
nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId:
AllocationID{05d74ea6e1d13567abebde6112fefd12}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-3] 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{44b6bf7b7ab9ca5648cfa13a5fae5f72}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-3] 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{c43db2ae1a7ae2a78206c8371f56c401}, jobId:
a2008824fc98b68a08a20655ceff1343).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
a2008824fc98b68a08a20655ceff1343 from job leader monitoring.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job a2008824fc98b68a08a20655ceff1343.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-abda807e-f666-4bbf-b1cd-a69f621ae46f
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[ForkJoinPool.commonPool-worker-11] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-6] 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.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherf31e4491-fb62-4167-a558-ea2e9b24220d.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:33615
[flink-akka.actor.default-dispatcher-7] 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 9985 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@e12fd0b1
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1207122550-5f7d3b72_a6ff1ab6-2d30-4c80-9629-6d98a4c871e7/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-1207122550-5f7d3b72_a6ff1ab6-2d30-4c80-9629-6d98a4c871e7/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:40305
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:41221
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 4 failed, 2 skipped
Finished generating test XML results (1.454 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.998 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 7,5,main]) completed. Took 41 mins 24.705
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 45m 1s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/anpyg6k5pqdea
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]
