Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming #95

[Apache Jenkins Server <je...@builds.apache.org>]

See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/95/display/redirect?page=changes>

Changes:

[mxm] [BEAM-1628] Allow empty port for flink master url

------------------------------------------
[...truncated 549.44 MB...]
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (9/16) (96ebfce077ea0b24ac71932766eab5f5) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/16) (3b24387d7df82eaadf54f1642ec5af68) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/16) (3b24387d7df82eaadf54f1642ec5af68).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (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/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (9/16) (551a40a4b54ae079a491c36a78e27fbb) [FINISHED]
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16) (3b24387d7df82eaadf54f1642ec5af68) [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/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} 1c04d3f242da06b951d7f3a35252d643.
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (9/16) (96ebfce077ea0b24ac71932766eab5f5).
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (96ebfce077ea0b24ac71932766eab5f5) [FINISHED]
    [ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (5/16) (e742c8a2ebc7d500e04126ee6807b3d1) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (5/16) (e742c8a2ebc7d500e04126ee6807b3d1).
    [ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16) (e742c8a2ebc7d500e04126ee6807b3d1) [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/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} 9765bfb04610766352a7ad1dded2ae51.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (12/16) (99c7a789f540f0cdd7b19df16a3c8250) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (12/16) (99c7a789f540f0cdd7b19df16a3c8250).
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16) (99c7a789f540f0cdd7b19df16a3c8250) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (8/16) (a6893b8effd06606df241d5d0fd2da47) 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/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} 8593adb5fe36813223909266cc0d9fca.
    [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/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} 551a40a4b54ae079a491c36a78e27fbb.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (1/16) (1c04d3f242da06b951d7f3a35252d643) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 3b24387d7df82eaadf54f1642ec5af68.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 96ebfce077ea0b24ac71932766eab5f5.
    [ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (8/16) (1ba2a972b54eda0c3b02661264fbbd49) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (8/16) (1ba2a972b54eda0c3b02661264fbbd49).
    [ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16) (1ba2a972b54eda0c3b02661264fbbd49) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem e742c8a2ebc7d500e04126ee6807b3d1.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 99c7a789f540f0cdd7b19df16a3c8250.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 1ba2a972b54eda0c3b02661264fbbd49.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (5/16) (9765bfb04610766352a7ad1dded2ae51) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (12/16) (8593adb5fe36813223909266cc0d9fca) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (9/16) (551a40a4b54ae079a491c36a78e27fbb) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (3b24387d7df82eaadf54f1642ec5af68) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (96ebfce077ea0b24ac71932766eab5f5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (e742c8a2ebc7d500e04126ee6807b3d1) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (99c7a789f540f0cdd7b19df16a3c8250) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (1ba2a972b54eda0c3b02661264fbbd49) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (16/16) (54ed3a8ad3686e08ecb7bda67f781318) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (7/16) (cbab2e1ccf4e767c40ce4aa01407aa62) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (7/16) (cbab2e1ccf4e767c40ce4aa01407aa62).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (16/16) (54ed3a8ad3686e08ecb7bda67f781318).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (7/16) (cbab2e1ccf4e767c40ce4aa01407aa62) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (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/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (16/16) (54ed3a8ad3686e08ecb7bda67f781318) [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/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} cbab2e1ccf4e767c40ce4aa01407aa62.
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (16/16) (e2e5332d89da0298db1869e6992ead80) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (16/16) (e2e5332d89da0298db1869e6992ead80).
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (2349efd7db07957462885d2a32dc1cb3) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (2349efd7db07957462885d2a32dc1cb3).
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16) (e2e5332d89da0298db1869e6992ead80) [FINISHED]
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (2349efd7db07957462885d2a32dc1cb3) [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/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} 54ed3a8ad3686e08ecb7bda67f781318.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (3/16) (2bbdaa3fd19cd6d52ac3fa00b86e3c07) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (2/16) (60203995d16ae628127da844531317a2) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (3/16) (2bbdaa3fd19cd6d52ac3fa00b86e3c07).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (2/16) (60203995d16ae628127da844531317a2).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (3/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/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (3/16) (2bbdaa3fd19cd6d52ac3fa00b86e3c07) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (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/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (2/16) (60203995d16ae628127da844531317a2) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem e2e5332d89da0298db1869e6992ead80.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 2349efd7db07957462885d2a32dc1cb3.
    [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/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} 2bbdaa3fd19cd6d52ac3fa00b86e3c07.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (7/16) (cbab2e1ccf4e767c40ce4aa01407aa62) 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/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} 60203995d16ae628127da844531317a2.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (16/16) (54ed3a8ad3686e08ecb7bda67f781318) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (65abeff6429a7563c63487bbf0443414) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (65abeff6429a7563c63487bbf0443414).
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (65abeff6429a7563c63487bbf0443414) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 65abeff6429a7563c63487bbf0443414.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (16/16) (e2e5332d89da0298db1869e6992ead80) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (3/16) (c0e9de228bbaba702e0f718dd47db5cd) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (3/16) (c0e9de228bbaba702e0f718dd47db5cd).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (2349efd7db07957462885d2a32dc1cb3) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16) (c0e9de228bbaba702e0f718dd47db5cd) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem c0e9de228bbaba702e0f718dd47db5cd.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (3/16) (2bbdaa3fd19cd6d52ac3fa00b86e3c07) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (2/16) (60203995d16ae628127da844531317a2) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (65abeff6429a7563c63487bbf0443414) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (c0e9de228bbaba702e0f718dd47db5cd) switched from RUNNING to FINISHED.
    [grpc-default-executor-84] WARN org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not supported in the current execution environment. 
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (6673a725f22acde6cacdec934e78244f) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (6673a725f22acde6cacdec934e78244f).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (6673a725f22acde6cacdec934e78244f) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16) (a70b94c1ddaf644e3f16689c66763990) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16) (43f80abdf01ae670d5a0aeb283d46a7c) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16) (a70b94c1ddaf644e3f16689c66763990).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16) (43f80abdf01ae670d5a0aeb283d46a7c).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16) (a70b94c1ddaf644e3f16689c66763990) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16) (43f80abdf01ae670d5a0aeb283d46a7c) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16) (9935abd88719d0c613a65a36586ae801) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16) (9935abd88719d0c613a65a36586ae801).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16) (9935abd88719d0c613a65a36586ae801) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16) (51b52880f5b53c2bf1dbaddeb0fc2f7f) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16) (51b52880f5b53c2bf1dbaddeb0fc2f7f).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16) (51b52880f5b53c2bf1dbaddeb0fc2f7f) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (12f96fa1946f8cbc447cbadddd7bd3bd) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (12f96fa1946f8cbc447cbadddd7bd3bd).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (12f96fa1946f8cbc447cbadddd7bd3bd) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (c4b7ef6b7ece30ec151d4af2e105f572) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (4b442d485612423726e4191a669ae2e1) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (c4b7ef6b7ece30ec151d4af2e105f572).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (4b442d485612423726e4191a669ae2e1).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (c4b7ef6b7ece30ec151d4af2e105f572) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (4b442d485612423726e4191a669ae2e1) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 6673a725f22acde6cacdec934e78244f.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} a70b94c1ddaf644e3f16689c66763990.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (91e42133089ef62c2cd68d81f569b518) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16) (d2d12701ea5549cb9fe7e036283b8b09) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16) (d2d12701ea5549cb9fe7e036283b8b09).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (91e42133089ef62c2cd68d81f569b518).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16) (d2d12701ea5549cb9fe7e036283b8b09) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (91e42133089ef62c2cd68d81f569b518) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 43f80abdf01ae670d5a0aeb283d46a7c.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 9935abd88719d0c613a65a36586ae801.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 51b52880f5b53c2bf1dbaddeb0fc2f7f.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 12f96fa1946f8cbc447cbadddd7bd3bd.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} c4b7ef6b7ece30ec151d4af2e105f572.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 4b442d485612423726e4191a669ae2e1.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 91e42133089ef62c2cd68d81f569b518.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (9183d3d804ccc9a90766947e87f82972) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (9183d3d804ccc9a90766947e87f82972).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (9183d3d804ccc9a90766947e87f82972) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} d2d12701ea5549cb9fe7e036283b8b09.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 9183d3d804ccc9a90766947e87f82972.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (6673a725f22acde6cacdec934e78244f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (7/16) (a70b94c1ddaf644e3f16689c66763990) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (16/16) (43f80abdf01ae670d5a0aeb283d46a7c) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (6/16) (9935abd88719d0c613a65a36586ae801) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (12/16) (51b52880f5b53c2bf1dbaddeb0fc2f7f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (12f96fa1946f8cbc447cbadddd7bd3bd) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (5/16) (c4b7ef6b7ece30ec151d4af2e105f572) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (8/16) (4b442d485612423726e4191a669ae2e1) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (10/16) (91e42133089ef62c2cd68d81f569b518) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (13/16) (d2d12701ea5549cb9fe7e036283b8b09) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (9183d3d804ccc9a90766947e87f82972) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16) (07c9bf2adc75a33e7d7c13d2512f5815) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16) (07c9bf2adc75a33e7d7c13d2512f5815).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16) (07c9bf2adc75a33e7d7c13d2512f5815) [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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 07c9bf2adc75a33e7d7c13d2512f5815.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16) (3964c7153eb86f9e1f69ab3081ba2c45) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16) (3964c7153eb86f9e1f69ab3081ba2c45).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16) (3964c7153eb86f9e1f69ab3081ba2c45) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16) (2c11184f63ba0cd2bb2fcb1e8bba8cf6) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16) (2c11184f63ba0cd2bb2fcb1e8bba8cf6).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (d3171d3febc699f2f3ded448e7e22b91) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16) (2c11184f63ba0cd2bb2fcb1e8bba8cf6) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (d3171d3febc699f2f3ded448e7e22b91).
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (e73c5895d96bb5582e5e1b1dbc5eb842) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (d3171d3febc699f2f3ded448e7e22b91) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (e73c5895d96bb5582e5e1b1dbc5eb842).
    [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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 3964c7153eb86f9e1f69ab3081ba2c45.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (e73c5895d96bb5582e5e1b1dbc5eb842) [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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 2c11184f63ba0cd2bb2fcb1e8bba8cf6.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (14/16) (07c9bf2adc75a33e7d7c13d2512f5815) 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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} d3171d3febc699f2f3ded448e7e22b91.
    [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/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} e73c5895d96bb5582e5e1b1dbc5eb842.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (15/16) (3964c7153eb86f9e1f69ab3081ba2c45) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (1/16) (2c11184f63ba0cd2bb2fcb1e8bba8cf6) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (d3171d3febc699f2f3ded448e7e22b91) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (e73c5895d96bb5582e5e1b1dbc5eb842) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1204150439-2db8728e (97629ca90fe761b952d29c6c94b20425) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 97629ca90fe761b952d29c6c94b20425.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 97629ca90fe761b952d29c6c94b20425 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-1204150439-2db8728e(97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 97629ca90fe761b952d29c6c94b20425.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection f46aca746a8843071d4aad079d87d0b4: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager a6ff6d148c01fa43f925b2ee4cd544b7@akka://flink/user/jobmanager_261 for job 97629ca90fe761b952d29c6c94b20425 from the resource manager.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 97629ca90fe761b952d29c6c94b20425 with leader id a6ff6d148c01fa43f925b2ee4cd544b7 lost leadership.
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
    [flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher3b81853f-0c85-495e-82e7-f7d021d64eeb.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher3b81853f-0c85-495e-82e7-f7d021d64eeb.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher3b81853f-0c85-495e-82e7-f7d021d64eeb.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{ded58a29e73c3cef7d07bdba4cfcd555}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{47be5c01635247d3dbf765b1c82eebce}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] 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{0d57c872ef57e40e44ced70a290294f4}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{200525cad4192056cc08bed0287227b5}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{379249065a30e77174b3efe062d7b9bf}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{7ffc5d9ec4254c2424d9b461ca8429f9}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{4fa6107b4e61da4ce315d72659dd5e03}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] 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{4223f90d26199074a6d7facdc6c9cf97}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{039f116c3835dc59d33895fad957f04a}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{3278ee1994ebf31f19e335bd321038a1}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2e1509561cdb0984f121218c01be024a}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{e446fa9e2c0ce55ddab60d20d3c49691}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{bc4d73a851e6e1687241b0ff503e3afb}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{ef30e336f2a46ff1ad25d1a6d10dd22b}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{d210f5563799a45c613714009121486e}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{a64bc73ddb8b9a38b86132bd5d4464aa}, jobId: 97629ca90fe761b952d29c6c94b20425).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 97629ca90fe761b952d29c6c94b20425 from job leader monitoring.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 97629ca90fe761b952d29c6c94b20425.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-a76afdd2-74db-4a64-bd35-eb09bae35813
    [ForkJoinPool.commonPool-worker-13] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:40543
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 6240 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@a5adb30d
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1204150439-2db8728e_ddc27f77-0aa6-47f3-a846-18c88ac33d86/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-1204150439-2db8728e_ddc27f77-0aa6-47f3-a846-18c88ac33d86/
    [pool-22513-thread-1] WARN org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Hanged up for unknown endpoint.
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:40275
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:34937

Gradle Test Executor 1 finished executing tests.

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming

197 tests completed, 3 failed, 2 skipped
Finished generating test XML results (3.351 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.859 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 9,5,main]) completed. Took 33 mins 32.588 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 36m 27s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/vguigpv6kwkzu

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org