Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming #106

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

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

Changes:

[cyturel] BEAM-6151: MongoDbIO add support mongodb server with self signed ssl

[github] [BEAM-6182] Disable conscrypt by default (#7203)

------------------------------------------
[...truncated 550.63 MB...]
    [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 1ae3d4e80aab8b2b6710b78f6d981a62.
    [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} 256b5b720888526766a837b1d72dc4f5.
    [ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (10/16) (20535a2ff99202d8d279edfaebc2252d) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (10/16) (20535a2ff99202d8d279edfaebc2252d).
    [ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16) (20535a2ff99202d8d279edfaebc2252d) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] 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} (14/16) (5da8cf2b685dd5d5cf0424c303de8c90) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (3b42832a6507c5c65a75c4840e2feb44) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 20535a2ff99202d8d279edfaebc2252d.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (95b1be03d0b00d58a5728644cbd87394) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (11e0c6927eddd348a05a1d7059feecf5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} (11/16) (d57b7016e035add2768e60ec87a24cad) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (1ae3d4e80aab8b2b6710b78f6d981a62) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} (10/16) (256b5b720888526766a837b1d72dc4f5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (10/16) (20535a2ff99202d8d279edfaebc2252d) 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) (1daa0b9edea9bea9c61fbe0dfdfa8e5d) 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) (1daa0b9edea9bea9c61fbe0dfdfa8e5d).
    [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) (1daa0b9edea9bea9c61fbe0dfdfa8e5d) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} 1daa0b9edea9bea9c61fbe0dfdfa8e5d.
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (50db2c967f6515cb88a8bee049a92c1e) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (50db2c967f6515cb88a8bee049a92c1e).
    [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 - 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) (ca8ccaf17cc3706b01878daa11ccd073) 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} (9/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} (9/16) (ca8ccaf17cc3706b01878daa11ccd073).
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (50db2c967f6515cb88a8bee049a92c1e) [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} (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) (ca8ccaf17cc3706b01878daa11ccd073) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 50db2c967f6515cb88a8bee049a92c1e.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} ca8ccaf17cc3706b01878daa11ccd073.
    [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} (6/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} (6/16) (be8dbd0fec9463cfa7be2f5bff896afc) 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} (6/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} (6/16) (be8dbd0fec9463cfa7be2f5bff896afc).
    [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} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} (6/16) (be8dbd0fec9463cfa7be2f5bff896afc) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} be8dbd0fec9463cfa7be2f5bff896afc.
    [flink-akka.actor.default-dispatcher-5] 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) (1daa0b9edea9bea9c61fbe0dfdfa8e5d) 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 - 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) (1941c5df5939af113e8fed1cedf327f9) 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) (1941c5df5939af113e8fed1cedf327f9).
    [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) (1941c5df5939af113e8fed1cedf327f9) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} 1941c5df5939af113e8fed1cedf327f9.
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (9/16) (1e417ed9e3d7415cb5993c06a9cb7e02) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (9/16) (1e417ed9e3d7415cb5993c06a9cb7e02).
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (1e417ed9e3d7415cb5993c06a9cb7e02) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 1e417ed9e3d7415cb5993c06a9cb7e02.
    [ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (6/16) (47af1a6bac708b226721e30d168d5a16) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (6/16) (47af1a6bac708b226721e30d168d5a16).
    [ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) (47af1a6bac708b226721e30d168d5a16) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 47af1a6bac708b226721e30d168d5a16.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (50db2c967f6515cb88a8bee049a92c1e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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) (ca8ccaf17cc3706b01878daa11ccd073) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (3/16) (7dc3e2dcbd20f25c4c808afe8e573f25) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (3/16) (7dc3e2dcbd20f25c4c808afe8e573f25).
    [ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16) (7dc3e2dcbd20f25c4c808afe8e573f25) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 7dc3e2dcbd20f25c4c808afe8e573f25.
    [flink-akka.actor.default-dispatcher-5] 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} (6/16) (be8dbd0fec9463cfa7be2f5bff896afc) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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) (1941c5df5939af113e8fed1cedf327f9) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (1e417ed9e3d7415cb5993c06a9cb7e02) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (47af1a6bac708b226721e30d168d5a16) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (7dc3e2dcbd20f25c4c808afe8e573f25) 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) (d84adaa406725a00b0fbf742eb046f20) 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 - 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) (d84adaa406725a00b0fbf742eb046f20).
    [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) (d84adaa406725a00b0fbf742eb046f20) [FINISHED]
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (16/16) (075a33b90e02d514d3751d537c184117) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (16/16) (075a33b90e02d514d3751d537c184117).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} d84adaa406725a00b0fbf742eb046f20.
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16) (075a33b90e02d514d3751d537c184117) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 075a33b90e02d514d3751d537c184117.
    [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) (6c44e45c231b6f8535600fd9e4d2ccdb) 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 - 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) (6c44e45c231b6f8535600fd9e4d2ccdb).
    [flink-akka.actor.default-dispatcher-3] 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) (d84adaa406725a00b0fbf742eb046f20) 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 - 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) (6c44e45c231b6f8535600fd9e4d2ccdb) [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} 6c44e45c231b6f8535600fd9e4d2ccdb.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (16/16) (075a33b90e02d514d3751d537c184117) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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) (6c44e45c231b6f8535600fd9e4d2ccdb) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (1f8b44361cda14196462b7d36c18a839) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (1f8b44361cda14196462b7d36c18a839).
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (1f8b44361cda14196462b7d36c18a839) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 1f8b44361cda14196462b7d36c18a839.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (1f8b44361cda14196462b7d36c18a839) switched from RUNNING to FINISHED.
    [grpc-default-executor-143] 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)} (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) (6017ce28af0a4cef9704560948c11062) 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 - 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) (6017ce28af0a4cef9704560948c11062).
    [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) (2cac134245e9f9f197910f25ca8be3f5) 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) (2cac134245e9f9f197910f25ca8be3f5).
    [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) (6017ce28af0a4cef9704560948c11062) [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) (2cac134245e9f9f197910f25ca8be3f5) [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)} 6017ce28af0a4cef9704560948c11062.
    [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)} 2cac134245e9f9f197910f25ca8be3f5.
    [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) (5e998d78d52339e5853414bba45c896b) 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) (5e998d78d52339e5853414bba45c896b).
    [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) (5e998d78d52339e5853414bba45c896b) [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) (4be3e7f62ccc1ddc94108ef423f749eb) 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) (4be3e7f62ccc1ddc94108ef423f749eb).
    [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) (4be3e7f62ccc1ddc94108ef423f749eb) [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)} 5e998d78d52339e5853414bba45c896b.
    [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)} 4be3e7f62ccc1ddc94108ef423f749eb.
    [flink-akka.actor.default-dispatcher-3] 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) (6017ce28af0a4cef9704560948c11062) 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) (28203ba1537e4352899ca75859bb73c7) 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 - 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) (28203ba1537e4352899ca75859bb73c7).
    [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) (28203ba1537e4352899ca75859bb73c7) [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) (a37a536403b6cb65087ae807665a8396) 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) (a37a536403b6cb65087ae807665a8396).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 28203ba1537e4352899ca75859bb73c7.
    [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) (a37a536403b6cb65087ae807665a8396) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} a37a536403b6cb65087ae807665a8396.
    [flink-akka.actor.default-dispatcher-3] 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) (2cac134245e9f9f197910f25ca8be3f5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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) (5e998d78d52339e5853414bba45c896b) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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) (4be3e7f62ccc1ddc94108ef423f749eb) 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) (3901eeb759f69df5fb5e5fc1c6d57fbe) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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) (28203ba1537e4352899ca75859bb73c7) 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) (3901eeb759f69df5fb5e5fc1c6d57fbe).
    [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) (3901eeb759f69df5fb5e5fc1c6d57fbe) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 3901eeb759f69df5fb5e5fc1c6d57fbe.
    [flink-akka.actor.default-dispatcher-3] 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) (a37a536403b6cb65087ae807665a8396) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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) (3901eeb759f69df5fb5e5fc1c6d57fbe) 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 - 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) (005d8dc970ffbdd1ad30fda345b84205) 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) (005d8dc970ffbdd1ad30fda345b84205).
    [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) (005d8dc970ffbdd1ad30fda345b84205) [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)} 005d8dc970ffbdd1ad30fda345b84205.
    [flink-akka.actor.default-dispatcher-5] 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) (005d8dc970ffbdd1ad30fda345b84205) 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 - 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) (3833d171b9daffd999f1d7a2c7896c65) 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) (3833d171b9daffd999f1d7a2c7896c65).
    [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) (3833d171b9daffd999f1d7a2c7896c65) [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) (276377646ef71c9bb173023c73b3f76c) 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 - 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) (276377646ef71c9bb173023c73b3f76c).
    [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) (276377646ef71c9bb173023c73b3f76c) [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 - 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) (51f971611ba23f56aa06432c5d75014f) 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) (51f971611ba23f56aa06432c5d75014f).
    [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) (8011e02b5593664d6b8e23b89c49d565) 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) (8011e02b5593664d6b8e23b89c49d565).
    [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) (fff6cc181931ab5b0e308e6fbdd110cd) 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 - 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) (51f971611ba23f56aa06432c5d75014f) [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 - 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) (fff6cc181931ab5b0e308e6fbdd110cd).
    [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) (8011e02b5593664d6b8e23b89c49d565) [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) (fff6cc181931ab5b0e308e6fbdd110cd) [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) (c53f4802ec5b8e3e933d2b7ae4053cc0) 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 - 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) (2fef7be9685a11500a247f36a2607df6) 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) (c53f4802ec5b8e3e933d2b7ae4053cc0).
    [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) (2fef7be9685a11500a247f36a2607df6).
    [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) (c53f4802ec5b8e3e933d2b7ae4053cc0) [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 - 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) (2fef7be9685a11500a247f36a2607df6) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 3833d171b9daffd999f1d7a2c7896c65.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 276377646ef71c9bb173023c73b3f76c.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 51f971611ba23f56aa06432c5d75014f.
    [flink-akka.actor.default-dispatcher-6] 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) (3833d171b9daffd999f1d7a2c7896c65) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 8011e02b5593664d6b8e23b89c49d565.
    [flink-akka.actor.default-dispatcher-6] 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) (276377646ef71c9bb173023c73b3f76c) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} fff6cc181931ab5b0e308e6fbdd110cd.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} c53f4802ec5b8e3e933d2b7ae4053cc0.
    [flink-akka.actor.default-dispatcher-6] 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) (51f971611ba23f56aa06432c5d75014f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 2fef7be9685a11500a247f36a2607df6.
    [flink-akka.actor.default-dispatcher-6] 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) (8011e02b5593664d6b8e23b89c49d565) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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) (fff6cc181931ab5b0e308e6fbdd110cd) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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) (c53f4802ec5b8e3e933d2b7ae4053cc0) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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) (2fef7be9685a11500a247f36a2607df6) 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)} (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) (a0080903bdfb027208cc6690248c1225) 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)} (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) (a0080903bdfb027208cc6690248c1225).
    [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) (a0080903bdfb027208cc6690248c1225) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} a0080903bdfb027208cc6690248c1225.
    [flink-akka.actor.default-dispatcher-4] 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) (a0080903bdfb027208cc6690248c1225) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1205191817-e8ea344 (489f094c2aadf5db53ce6223324443d5) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 489f094c2aadf5db53ce6223324443d5.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 489f094c2aadf5db53ce6223324443d5 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-1205191817-e8ea344(489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 489f094c2aadf5db53ce6223324443d5.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 8a488247c6dacc2901010c3639e05448: JobManager is shutting down..
    [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.resourcemanager.StandaloneResourceManager - Disconnect job manager 9a3a3b29ea97d8603f988ba1c21e48aa@akka://flink/user/jobmanager_261 for job 489f094c2aadf5db53ce6223324443d5 from the resource manager.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 489f094c2aadf5db53ce6223324443d5 with leader id 9a3a3b29ea97d8603f988ba1c21e48aa 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-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatchere504499f-d63d-4caf-8fd9-45adfbf4343f.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatchere504499f-d63d-4caf-8fd9-45adfbf4343f.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-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-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatchere504499f-d63d-4caf-8fd9-45adfbf4343f.
    [flink-akka.actor.default-dispatcher-3] 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{f6d1774386ef3484bd2a9f5decbcc289}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{42a48766fb15245460ee1501f43d6169}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{4712eb3ad526df163a82ce435e935ab6}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{1ab946da0239bcb65f9e5cf85b2c7b49}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{8733986d0d0d03656ef53507eeba79bc}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{61923a0a01aa168000c2da55d990e883}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{0b6b451f0b449bfb784d0cbddc921d42}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{636f2cd9d74616bdc90be8b542943578}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{5d78da173abeacf8efdd56875da5fd17}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{da518c7e70938641d4a3d34cf1813ffc}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{4c001619d8bad21a73b5d7617bcb3bd9}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{b9ea61d094533d9665c26b8dc2dddd86}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{4baea7558da35c0dcc0bcd2e9105ea5a}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{f5888785bab5a6b363a34dc3db0d8604}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{979e006b3a3c9110dba56abf74cddc11}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] 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{61963663601fd14b78f19603459b7b32}, jobId: 489f094c2aadf5db53ce6223324443d5).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 489f094c2aadf5db53ce6223324443d5 from job leader monitoring.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 489f094c2aadf5db53ce6223324443d5.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 489f094c2aadf5db53ce6223324443d5.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-5d494b7e-01ad-43c7-8368-e884629779b8
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
    [ForkJoinPool.commonPool-worker-4] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-4] 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:37213
    [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 6583 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@4ae17e90
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1205191817-e8ea344_44d08194-7718-49a5-a134-f322b20ca473/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-1205191817-e8ea344_44d08194-7718-49a5-a134-f322b20ca473/
    [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:44403
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:37983

Gradle Test Executor 2 finished executing tests.

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

197 tests completed, 3 failed, 2 skipped
Finished generating test XML results (3.471 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.907 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 34 mins 21.594 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 37m 54s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

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

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