Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming #94

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

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

Changes:

[katarzyna.kucharczyk] [BEAM-5778] Add integrations of Metrics API to Big Query for

[vaclav.plajt] [BEAM-6174] Kryo dependency removed.

------------------------------------------
[...truncated 547.17 MB...]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (12/16)] 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} (12/16) (91b7a8bb8e27eb1841a07acbf3336331) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) (ac34a738cd68ff4748072d5616415bed) [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} (12/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} (12/16) (91b7a8bb8e27eb1841a07acbf3336331).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem ac34a738cd68ff4748072d5616415bed.
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (12/16)] 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} (12/16) (91b7a8bb8e27eb1841a07acbf3336331) [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} 91b7a8bb8e27eb1841a07acbf3336331.
    [flink-akka.actor.default-dispatcher-4] 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} (13/16) (1f469c7e4a7c167c10481ebd6f9edb9c) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (12/16) (ab8678eb1c210642fbad0437753c361c) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (12/16) (ab8678eb1c210642fbad0437753c361c).
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16) (ab8678eb1c210642fbad0437753c361c) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (ac34a738cd68ff4748072d5616415bed) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem ab8678eb1c210642fbad0437753c361c.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (12/16) (91b7a8bb8e27eb1841a07acbf3336331) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (ab8678eb1c210642fbad0437753c361c) 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} (14/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} (14/16) (8976ba1a9d242b72b9f866c3e4233eb6) 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} (14/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} (14/16) (8976ba1a9d242b72b9f866c3e4233eb6).
    [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)] 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} (14/16) (8976ba1a9d242b72b9f866c3e4233eb6) [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} 8976ba1a9d242b72b9f866c3e4233eb6.
    [ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (14/16) (d2378a12147741f69db8a7ea6d49b173) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (14/16) (d2378a12147741f69db8a7ea6d49b173).
    [ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (d2378a12147741f69db8a7ea6d49b173) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem d2378a12147741f69db8a7ea6d49b173.
    [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} (15/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} (15/16) (2346f7233c9b7508e877923859acd821) 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} (15/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} (15/16) (2346f7233c9b7508e877923859acd821).
    [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} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} (15/16) (2346f7233c9b7508e877923859acd821) [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) (8976ba1a9d242b72b9f866c3e4233eb6) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (15/16) (27477ec32ceec61abea0c1097546dd10) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (15/16) (27477ec32ceec61abea0c1097546dd10).
    [ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) (27477ec32ceec61abea0c1097546dd10) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (d2378a12147741f69db8a7ea6d49b173) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} 2346f7233c9b7508e877923859acd821.
    [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 27477ec32ceec61abea0c1097546dd10.
    [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} (15/16) (2346f7233c9b7508e877923859acd821) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (27477ec32ceec61abea0c1097546dd10) 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} (1/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} (1/16) (7a9c449fcf21b7b0f9c21a56c4f93dcd) 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} (1/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} (1/16) (7a9c449fcf21b7b0f9c21a56c4f93dcd).
    [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) (6df01136422966d0948fb8a559f9b9a4) 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) (6df01136422966d0948fb8a559f9b9a4).
    [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) (0a8599c1980e0d19553194ac42ee374f) 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) (0a8599c1980e0d19553194ac42ee374f).
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (1/16)] 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} (1/16) (7a9c449fcf21b7b0f9c21a56c4f93dcd) [FINISHED]
    [PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (16/16) (6df01136422966d0948fb8a559f9b9a4) [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) (0a8599c1980e0d19553194ac42ee374f) [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} 7a9c449fcf21b7b0f9c21a56c4f93dcd.
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (16/16) (20b3e2ad363f84068b0e95fd9bc4e34a) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (16/16) (20b3e2ad363f84068b0e95fd9bc4e34a).
    [ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16) (20b3e2ad363f84068b0e95fd9bc4e34a) [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} 6df01136422966d0948fb8a559f9b9a4.
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (9/16) (7ec934df4a5ae85f97c49d3fae9bfcad) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (9/16) (7ec934df4a5ae85f97c49d3fae9bfcad).
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/16) (54a6611ca3265c0d19fdf8806d535e66) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/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} 0a8599c1980e0d19553194ac42ee374f.
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/16) (54a6611ca3265c0d19fdf8806d535e66).
    [ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (7ec934df4a5ae85f97c49d3fae9bfcad) [FINISHED]
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16) (54a6611ca3265c0d19fdf8806d535e66) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]{PAssert$155/GroupGlobally/GatherAllOutputs/Values/Values/Map, PAssert$155/GroupGlobally/RewindowActuals/Window.Assign, PAssert$155/GroupGlobally/KeyForDummy/AddKeys/Map, PAssert$155/GroupGlobally/RemoveActualsTriggering/Flatten.PCollections, PAssert$155/GroupGlobally/FlattenDummyAndContents, PAssert$155/GroupGlobally/NeverTrigger/Flatten.PCollections} (1/16) (7a9c449fcf21b7b0f9c21a56c4f93dcd) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 20b3e2ad363f84068b0e95fd9bc4e34a.
    [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 7ec934df4a5ae85f97c49d3fae9bfcad.
    [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 54a6611ca3265c0d19fdf8806d535e66.
    [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) (0555d6985908202df408220c077ca8c9) 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) (0555d6985908202df408220c077ca8c9).
    [flink-akka.actor.default-dispatcher-2] 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) (6df01136422966d0948fb8a559f9b9a4) 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) (0555d6985908202df408220c077ca8c9) [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} 0555d6985908202df408220c077ca8c9.
    [flink-akka.actor.default-dispatcher-2] 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) (0a8599c1980e0d19553194ac42ee374f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (16/16) (20b3e2ad363f84068b0e95fd9bc4e34a) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (7ec934df4a5ae85f97c49d3fae9bfcad) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (54a6611ca3265c0d19fdf8806d535e66) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (f5d767a7a43aaabafdaa8dd8907a1506) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (f5d767a7a43aaabafdaa8dd8907a1506).
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (f5d767a7a43aaabafdaa8dd8907a1506) [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 f5d767a7a43aaabafdaa8dd8907a1506.
    [flink-akka.actor.default-dispatcher-2] 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) (0555d6985908202df408220c077ca8c9) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (f5d767a7a43aaabafdaa8dd8907a1506) switched from RUNNING to FINISHED.
    [grpc-default-executor-148] WARN org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not supported in the current execution environment. 
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (ba295b3a29535f2627dea6d1d8359710) 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) (ba295b3a29535f2627dea6d1d8359710).
    [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) (ba295b3a29535f2627dea6d1d8359710) [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) (f6db0dd201e1ad6e27a5b2fbe44a2d6b) 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) (f6db0dd201e1ad6e27a5b2fbe44a2d6b).
    [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) (f6db0dd201e1ad6e27a5b2fbe44a2d6b) [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)} ba295b3a29535f2627dea6d1d8359710.
    [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)} f6db0dd201e1ad6e27a5b2fbe44a2d6b.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (3/16) (ba295b3a29535f2627dea6d1d8359710) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (11/16) (f6db0dd201e1ad6e27a5b2fbe44a2d6b) 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) (f6af04ee6875b1e08c03cd1c680b9bbb) 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) (f6af04ee6875b1e08c03cd1c680b9bbb).
    [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) (f6af04ee6875b1e08c03cd1c680b9bbb) [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)} f6af04ee6875b1e08c03cd1c680b9bbb.
    [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)} (8/16) (f6af04ee6875b1e08c03cd1c680b9bbb) 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 - 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) (ee33ed7c22cad06c5efce2caf77ae34f) 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) (ee33ed7c22cad06c5efce2caf77ae34f).
    [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) (9814913f23e049dc1cec485617ed617f) 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 - 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) (75317a8a67882af3ced826fb2298f5d5) 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) (9814913f23e049dc1cec485617ed617f).
    [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) (75317a8a67882af3ced826fb2298f5d5).
    [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) (ee33ed7c22cad06c5efce2caf77ae34f) [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 - 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) (9814913f23e049dc1cec485617ed617f) [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)} ee33ed7c22cad06c5efce2caf77ae34f.
    [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) (75317a8a67882af3ced826fb2298f5d5) [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)} 9814913f23e049dc1cec485617ed617f.
    [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)} 75317a8a67882af3ced826fb2298f5d5.
    [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)} (7/16) (ee33ed7c22cad06c5efce2caf77ae34f) 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) (1ea6b29f7706e91395f8c5cdc7f99960) switched from RUNNING to FINISHED.
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (9/16) (1ea6b29f7706e91395f8c5cdc7f99960).
    [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) (43c5dc68d04dffe4cf095bd86e1e4afc) 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 - 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) (1ea6b29f7706e91395f8c5cdc7f99960) [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) (8eda056894b970d975d286e0300a5f11) 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) (43c5dc68d04dffe4cf095bd86e1e4afc).
    [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) (4a3381c60fac810ea58f66c6ebe2474b) 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) (8eda056894b970d975d286e0300a5f11).
    [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) (4a3381c60fac810ea58f66c6ebe2474b).
    [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)} 1ea6b29f7706e91395f8c5cdc7f99960.
    [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) (43c5dc68d04dffe4cf095bd86e1e4afc) [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 - 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) (8eda056894b970d975d286e0300a5f11) [FINISHED]
    [PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (2/16) (4a3381c60fac810ea58f66c6ebe2474b) [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) (dcfd47c797a05d2870349e37984e3498) 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) (dcfd47c797a05d2870349e37984e3498).
    [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) (dcfd47c797a05d2870349e37984e3498) [FINISHED]
    [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)} (6/16) (9814913f23e049dc1cec485617ed617f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 43c5dc68d04dffe4cf095bd86e1e4afc.
    [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)} 4a3381c60fac810ea58f66c6ebe2474b.
    [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) (6564c76b2b561a7c4ab28ab93f356cce) 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)} (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) (6564c76b2b561a7c4ab28ab93f356cce).
    [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) (6564c76b2b561a7c4ab28ab93f356cce) [FINISHED]
    [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)} (15/16) (75317a8a67882af3ced826fb2298f5d5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 8eda056894b970d975d286e0300a5f11.
    [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) (c9bb21969a7d0f968db5c1b9af239877) 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) (c9bb21969a7d0f968db5c1b9af239877).
    [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) (c9bb21969a7d0f968db5c1b9af239877) [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)} dcfd47c797a05d2870349e37984e3498.
    [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)} (9/16) (1ea6b29f7706e91395f8c5cdc7f99960) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/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)} 6564c76b2b561a7c4ab28ab93f356cce.
    [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)} c9bb21969a7d0f968db5c1b9af239877.
    [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)} (5/16) (43c5dc68d04dffe4cf095bd86e1e4afc) switched from RUNNING to FINISHED.
    [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)} (2/16) (4a3381c60fac810ea58f66c6ebe2474b) 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 - 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) (882eed18a6f18ca49cc623068a0c2c95) 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) (882eed18a6f18ca49cc623068a0c2c95).
    [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) (882eed18a6f18ca49cc623068a0c2c95) [FINISHED]
    [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)} (13/16) (8eda056894b970d975d286e0300a5f11) 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)} 882eed18a6f18ca49cc623068a0c2c95.
    [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)} (14/16) (dcfd47c797a05d2870349e37984e3498) 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 - 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) (c4ee370e9325b59b1e62b43082a26897) 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) (c4ee370e9325b59b1e62b43082a26897).
    [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) (c4ee370e9325b59b1e62b43082a26897) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} c4ee370e9325b59b1e62b43082a26897.
    [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)} (10/16) (6564c76b2b561a7c4ab28ab93f356cce) switched from RUNNING to FINISHED.
    [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)} (16/16) (c9bb21969a7d0f968db5c1b9af239877) switched from RUNNING to FINISHED.
    [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)} (1/16) (882eed18a6f18ca49cc623068a0c2c95) switched from RUNNING to FINISHED.
    [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)} (12/16) (c4ee370e9325b59b1e62b43082a26897) 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) (37e45516c556ec0c2244b896e6fbbb61) 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) (37e45516c556ec0c2244b896e6fbbb61).
    [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) (37e45516c556ec0c2244b896e6fbbb61) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} 37e45516c556ec0c2244b896e6fbbb61.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> [5]{PAssert$155/GroupGlobally/Values/Values/Map, PAssert$155/GroupGlobally/ParDo(Concat)/ParMultiDo(Concat), PAssert$155/GetPane/Map, PAssert$155/RunChecks/ParMultiDo(GroupedValuesChecker), PAssert$155/VerifyAssertions/ParDo(DefaultConclude)/ParMultiDo(DefaultConclude)} (4/16) (37e45516c556ec0c2244b896e6fbbb61) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1204141629-c3f9c249 (4b30f2ce6698b4aa773bab49f781450a) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 4b30f2ce6698b4aa773bab49f781450a.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 4b30f2ce6698b4aa773bab49f781450a reached globally terminal state FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1204141629-c3f9c249(4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 4b30f2ce6698b4aa773bab49f781450a.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 54c11f7f0da75529b5d494a85bcf45ec: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-4] 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 911ee50c2c1c72091343b3295c364aff@akka://flink/user/jobmanager_261 for job 4b30f2ce6698b4aa773bab49f781450a from the resource manager.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 4b30f2ce6698b4aa773bab49f781450a with leader id 911ee50c2c1c72091343b3295c364aff 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-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcherafba33fd-c527-4698-a258-d9940acce42b.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherafba33fd-c527-4698-a258-d9940acce42b.
    [flink-akka.actor.default-dispatcher-5] 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{f1b28275845f76c7fe3446293bce6cfb}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-5] 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{908cb256d706aa0b752ad9d7a7a96fe1}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{b1783d5184557e38041a6c3e364e3e22}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{5f1f42886b3f363fc5c74e199123d0c3}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.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{184d3c0b1248150af2a004591aa2dceb}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcherafba33fd-c527-4698-a258-d9940acce42b.
    [flink-akka.actor.default-dispatcher-5] 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{4402c362114278882eabd67f2e3ab06f}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{a7713d5896ebfb78dfc26f9c25cb95a9}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{fe19d91414b6d9b2a2f3cbe3e34791d4}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{bcca5ac3c2a48157368374184d5046e3}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{3a773ae6d4e2142a492f34b0c9c44de9}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{e8b4ef4fa6b2f3cbe6a55bc41bc525ac}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{ae6382b114e21b7e81887d000370a034}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{6cdfc2ff0e366d25fa2c1dd3548d2505}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-5] 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{7a50133c2bc7d529355d58d94666b07c}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-4] 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{f7a635a0c904800aba0d7719c71d0d8f}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-4] 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{731e29a43f4e539c51752257a50133e1}, jobId: 4b30f2ce6698b4aa773bab49f781450a).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 4b30f2ce6698b4aa773bab49f781450a from job leader monitoring.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 4b30f2ce6698b4aa773bab49f781450a.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 4b30f2ce6698b4aa773bab49f781450a.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-6e102d2d-286b-4f9b-9147-53845b10f73a
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
    [ForkJoinPool.commonPool-worker-13] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-13] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:33427
    [flink-akka.actor.default-dispatcher-2] 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 6209 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@538e3a01
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1204141629-c3f9c249_f625fd85-604c-4eed-90fb-1c90c8080087/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-1204141629-c3f9c249_f625fd85-604c-4eed-90fb-1c90c8080087/
    [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:39149
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:45597

Gradle Test Executor 1 finished executing tests.

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

197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (3.363 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.988 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 32 mins 47.992 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 36m 13s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/2fc4pneaqwfj4

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

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming #95

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

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

Changes:

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

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

Gradle Test Executor 1 finished executing tests.

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

197 tests completed, 3 failed, 2 skipped
Finished generating test XML results (3.351 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (1.859 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming (Thread[Task worker for ':' Thread 9,5,main]) completed. Took 33 mins 32.588 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 36m 27s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

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

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

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