See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/129/display/redirect?page=changes>
Changes:
[lcwik] [BEAM-6195] Make ProcessRemoteBundleOperation map PCollectionId into
------------------------------------------
[...truncated 232.46 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
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
84266b0dce09389094a4c75f05c1d824.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (9/16)
(a63ddef23aa3bffa9ccbc3123c77dc4a).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)
(c952ed71fefe8e382572d94f486fe9f9) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)
(1ef105a9d2e6b5f3f10c74f950424ccd) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16)
(a63ddef23aa3bffa9ccbc3123c77dc4a) [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
c84dbdea36e220925d401f6ab72d8be2.
[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
b9a613365bd817a49b273a723df5bd6d.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (4/16) (ca652c789a8c47279cfc8a36dab26884) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (4/16)
(ca652c789a8c47279cfc8a36dab26884).
[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}
c952ed71fefe8e382572d94f486fe9f9.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16)
(ca652c789a8c47279cfc8a36dab26884) [FINISHED]
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (10/16) (9a1b19951c5f029832bf94433b7878e1) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (10/16)
(9a1b19951c5f029832bf94433b7878e1).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)
(03bf7b306ee891bbf625124bf4a66a4c) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16)
(9a1b19951c5f029832bf94433b7878e1) [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
a63ddef23aa3bffa9ccbc3123c77dc4a.
[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
ca652c789a8c47279cfc8a36dab26884.
[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
9a1b19951c5f029832bf94433b7878e1.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)
(65d17759a74db7b7b59229b8af6fadfb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)
(84266b0dce09389094a4c75f05c1d824) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16)
(c84dbdea36e220925d401f6ab72d8be2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16)
(b9a613365bd817a49b273a723df5bd6d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (4/16)
(c952ed71fefe8e382572d94f486fe9f9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16)
(a63ddef23aa3bffa9ccbc3123c77dc4a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16)
(ca652c789a8c47279cfc8a36dab26884) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(10/16) (9a1b19951c5f029832bf94433b7878e1) 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)
(01670a3f4fdcc323d558eab1d3347258) 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 - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16)
(01670a3f4fdcc323d558eab1d3347258).
[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)
(01670a3f4fdcc323d558eab1d3347258) [FINISHED]
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(0be8e2c1aa1f9a69cbde9376cadbf565) 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)
(bae797e9c3deaa5809925534f679c1d9) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Freeing task resources for
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(0be8e2c1aa1f9a69cbde9376cadbf565).
[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)
(bae797e9c3deaa5809925534f679c1d9).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
01670a3f4fdcc323d558eab1d3347258.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO
org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are
closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)
(0be8e2c1aa1f9a69cbde9376cadbf565) [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 - 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)
(bae797e9c3deaa5809925534f679c1d9) [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 -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)
(c5b2769485235ed7e01a8d28a0562b75) 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)
(c5b2769485235ed7e01a8d28a0562b75).
[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)
(c5b2769485235ed7e01a8d28a0562b75) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
0be8e2c1aa1f9a69cbde9376cadbf565.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (14/16) (8ae37e97f9f534ad3e6a69f8a4eb35b5) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (14/16)
(8ae37e97f9f534ad3e6a69f8a4eb35b5).
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16)
(8ae37e97f9f534ad3e6a69f8a4eb35b5) [FINISHED]
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (15/16) (1e62964b2e072063f38b6019a0df835d) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (15/16)
(1e62964b2e072063f38b6019a0df835d).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
bae797e9c3deaa5809925534f679c1d9.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16)
(1e62964b2e072063f38b6019a0df835d) [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)
(01670a3f4fdcc323d558eab1d3347258) 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/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger}
c5b2769485235ed7e01a8d28a0562b75.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
8ae37e97f9f534ad3e6a69f8a4eb35b5.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
1e62964b2e072063f38b6019a0df835d.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (16/16) (5b45e330c88a542294df8ef84ca49ad1) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (13/16) (f5b6ee7aa64c13ed50a8497c568da08d) switched from
RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (13/16)
(f5b6ee7aa64c13ed50a8497c568da08d).
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (16/16)
(5b45e330c88a542294df8ef84ca49ad1).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16)
(f5b6ee7aa64c13ed50a8497c568da08d) [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} (14/16)
(0be8e2c1aa1f9a69cbde9376cadbf565) 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 ToKeyedWorkItem
f5b6ee7aa64c13ed50a8497c568da08d.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16)
(5b45e330c88a542294df8ef84ca49ad1) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task ToKeyedWorkItem
5b45e330c88a542294df8ef84ca49ad1.
[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)
(bae797e9c3deaa5809925534f679c1d9) 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} (13/16)
(c5b2769485235ed7e01a8d28a0562b75) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(14/16) (8ae37e97f9f534ad3e6a69f8a4eb35b5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(15/16) (1e62964b2e072063f38b6019a0df835d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(13/16) (f5b6ee7aa64c13ed50a8497c568da08d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem
(16/16) (5b45e330c88a542294df8ef84ca49ad1) switched from RUNNING to FINISHED.
[grpc-default-executor-128] 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)
(fa5903ccf29a5fd9f06aa7769a153c0e) 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)
(fa5903ccf29a5fd9f06aa7769a153c0e).
[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)
(fa5903ccf29a5fd9f06aa7769a153c0e) [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}
fa5903ccf29a5fd9f06aa7769a153c0e.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
ToKeyedWorkItem (2/16) (4d53dff1f25802928a7bfc2eed6c83c0) switched from RUNNING
to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Freeing task resources for ToKeyedWorkItem (2/16)
(4d53dff1f25802928a7bfc2eed6c83c0).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task -
Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16)
(4d53dff1f25802928a7bfc2eed6c83c0) [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
4d53dff1f25802928a7bfc2eed6c83c0.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey ->
[6]PAssert$155/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy,
RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)
(fa5903ccf29a5fd9f06aa7769a153c0e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16)
(4d53dff1f25802928a7bfc2eed6c83c0) 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)
(f2852271c30eab699743db09d6a61db8) 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)
(f2852271c30eab699743db09d6a61db8).
[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)
(f2852271c30eab699743db09d6a61db8) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)
(5e443c377991d4e876d2e40068bee0a6) 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)
(5e443c377991d4e876d2e40068bee0a6).
[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)
(5e443c377991d4e876d2e40068bee0a6) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
f2852271c30eab699743db09d6a61db8.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
5e443c377991d4e876d2e40068bee0a6.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)
(f2852271c30eab699743db09d6a61db8) 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)
(66032aa0100fa20e560919f42dc85a32) 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)
(66032aa0100fa20e560919f42dc85a32).
[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)
(834d3c0506e7eb9f411a55dd849fcda5) 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)
(834d3c0506e7eb9f411a55dd849fcda5).
[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)
(66032aa0100fa20e560919f42dc85a32) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)
(834d3c0506e7eb9f411a55dd849fcda5) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
66032aa0100fa20e560919f42dc85a32.
[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)
(fcdad4e4e6ed33c81e49e2111a104643) 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)
(ef4b0d94f9d8e1bb1ad8ce80bd34fca7) 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)
(fcdad4e4e6ed33c81e49e2111a104643).
[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)
(ef4b0d94f9d8e1bb1ad8ce80bd34fca7).
[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)
(fcdad4e4e6ed33c81e49e2111a104643) [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)
(ef4b0d94f9d8e1bb1ad8ce80bd34fca7) [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} (16/16)
(5e443c377991d4e876d2e40068bee0a6) 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 -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(702c61b5eb07e6036cfb831c718ab0eb) 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 -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(c659c46b2f3cd83806b97c4ad53586c0) 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)
(702c61b5eb07e6036cfb831c718ab0eb).
[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)
(c659c46b2f3cd83806b97c4ad53586c0).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
834d3c0506e7eb9f411a55dd849fcda5.
[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)
(624f8e8f68d946691e08a6d0ba24026e) 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)
(624f8e8f68d946691e08a6d0ba24026e).
[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)
(702c61b5eb07e6036cfb831c718ab0eb) [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)
(217c25e8db8da7135bc8715ef2d090d1) 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)
(217c25e8db8da7135bc8715ef2d090d1).
[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)
(c659c46b2f3cd83806b97c4ad53586c0) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)]
INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)
(624f8e8f68d946691e08a6d0ba24026e) [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)
(217c25e8db8da7135bc8715ef2d090d1) [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} (13/16)
(66032aa0100fa20e560919f42dc85a32) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
ef4b0d94f9d8e1bb1ad8ce80bd34fca7.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
fcdad4e4e6ed33c81e49e2111a104643.
[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)
(8c58d7187911a4810c34ebc6aa18a277) 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)
(8c58d7187911a4810c34ebc6aa18a277).
[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)
(8c58d7187911a4810c34ebc6aa18a277) [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} (1/16)
(834d3c0506e7eb9f411a55dd849fcda5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
702c61b5eb07e6036cfb831c718ab0eb.
[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)
(97649c8d9a7c3fd2f72135f319e86e52) 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)
(97649c8d9a7c3fd2f72135f319e86e52).
[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)
(ef4b0d94f9d8e1bb1ad8ce80bd34fca7) 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 - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)
(97649c8d9a7c3fd2f72135f319e86e52) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
c659c46b2f3cd83806b97c4ad53586c0.
[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)
(72f33d31f6733b11742d4fbe7405cf43) 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)
(72f33d31f6733b11742d4fbe7405cf43).
[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)
(72f33d31f6733b11742d4fbe7405cf43) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)]
INFO org.apache.flink.runtime.taskmanager.Task -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(d3b926287cf8c705f9685e28c07a612b) 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)
(d3b926287cf8c705f9685e28c07a612b).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
624f8e8f68d946691e08a6d0ba24026e.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)
(fcdad4e4e6ed33c81e49e2111a104643) 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 - Ensuring all FileSystem
streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)
(d3b926287cf8c705f9685e28c07a612b) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
217c25e8db8da7135bc8715ef2d090d1.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)
(702c61b5eb07e6036cfb831c718ab0eb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
8c58d7187911a4810c34ebc6aa18a277.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)
(c659c46b2f3cd83806b97c4ad53586c0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
97649c8d9a7c3fd2f72135f319e86e52.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
72f33d31f6733b11742d4fbe7405cf43.
[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)
(624f8e8f68d946691e08a6d0ba24026e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
d3b926287cf8c705f9685e28c07a612b.
[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)
(217c25e8db8da7135bc8715ef2d090d1) 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)
(84eaefe1259c3b13844d77b31ad33a87) 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)
(84eaefe1259c3b13844d77b31ad33a87).
[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)
(84eaefe1259c3b13844d77b31ad33a87) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}
84eaefe1259c3b13844d77b31ad33a87.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph -
PAssert$155/GroupGlobally/GroupDummyAndContents ->
[5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)
(8c58d7187911a4810c34ebc6aa18a277) 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} (2/16)
(97649c8d9a7c3fd2f72135f319e86e52) 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} (10/16)
(72f33d31f6733b11742d4fbe7405cf43) 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} (12/16)
(d3b926287cf8c705f9685e28c07a612b) 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} (11/16)
(84eaefe1259c3b13844d77b31ad33a87) 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)
(9d3d93c605e34caf714e352de0447b95) 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)
(9d3d93c605e34caf714e352de0447b95).
[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)
(9d3d93c605e34caf714e352de0447b95) [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}
9d3d93c605e34caf714e352de0447b95.
[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)
(9d3d93c605e34caf714e352de0447b95) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1208022408-2df3bc6d
(bed88a86833e37058fe1d2ff0c022fab) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint
coordinator for job bed88a86833e37058fe1d2ff0c022fab.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore -
Shutting down
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
bed88a86833e37058fe1d2ff0c022fab 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-1208022408-2df3bc6d(bed88a86833e37058fe1d2ff0c022fab).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job bed88a86833e37058fe1d2ff0c022fab.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
87d6c60f0de4b40d5270619ec063f1f2: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect
job manager 81b6f18101e7dc00fc6f1f2064d64679@akka://flink/user/jobmanager_261
for job bed88a86833e37058fe1d2ff0c022fab from the resource manager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-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/dispatcher7cbd3fb8-d4bb-4667-ad32-4b83ad13bc6f.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher7cbd3fb8-d4bb-4667-ad32-4b83ad13bc6f.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
bed88a86833e37058fe1d2ff0c022fab with leader id
81b6f18101e7dc00fc6f1f2064d64679 lost leadership.
[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{790a442618505a8593a55997cbc34923}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{0dcca069d6172f0283f5ba0d1adc1a77}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{0dc0dabb14570416ec984faa16fd5c5e}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{42e2758b822e2e85a2d0c18ace2bd007}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{88c60b0eeb2ae4ac07ab071997b115cf}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{f50999c650b6599fcee5a77ea458d0c8}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{9139d04d0405d9c77ba66254a19b85d0}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{8f3217c90521a5b5c9c7bc5aeda7b450}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{ede2dda4e9c451f3225ae8e27e0217ac}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{d413c95522fef5de480b37e39f10dfe7}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{c8bfd11541096a02769ecee6985b2de3}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{ceb3e2f2116555836cc74fb2b70a634b}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[flink-akka.actor.default-dispatcher-7] 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{d313e7e291d50108f53383deb795033a}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{212ef8f2e43e0c3db21c5976663ccc9d}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[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{83f9fc0f493c47df50c9a7cbb6bfa6b5}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[flink-akka.actor.default-dispatcher-7] 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{5fa167bcf45b7eab7a049909a0efafc4}, jobId:
bed88a86833e37058fe1d2ff0c022fab).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job
bed88a86833e37058fe1d2ff0c022fab from job leader monitoring.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager
connection for job bed88a86833e37058fe1d2ff0c022fab.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-2261d05a-aa67-4da8-953c-e2e3a654ec94
[flink-akka.actor.default-dispatcher-7] 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.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher7cbd3fb8-d4bb-4667-ad32-4b83ad13bc6f.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-7] 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-4] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:43529
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 9845 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@dff52497
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1208022408-2df3bc6d_5c1c8bd1-d962-493d-8894-b7934dd9b726/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-1208022408-2df3bc6d_5c1c8bd1-d962-493d-8894-b7934dd9b726/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:38079
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:46087
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.507 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (1.036 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 11,5,main]) completed. Took 40 mins 59.479
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 58s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/bwcc6firxkn56
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]
