You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2019/01/04 17:23:02 UTC

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming #347

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

Changes:

[25622840+adude3141] BEAM-4110 fix and reenable ResourceIdTester.runResourceIdBattery

[25622840+adude3141] BEAM-4110 fixed deprecation warnings and cleanup

[25622840+adude3141] BEAM-4143 reenable sickbayed test, cleanup

------------------------------------------
[...truncated 186.82 MB...]
    [ToKeyedWorkItem (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (3/16) (99f9eb8ddcc7e57c5b6f92085626bae6) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 99f9eb8ddcc7e57c5b6f92085626bae6.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16) (1c0cf821cea290aee1912d67df95738f) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16) (1c0cf821cea290aee1912d67df95738f).
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16) (1c0cf821cea290aee1912d67df95738f) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (3/16) (a4dab6fe9c430e241d54baeb69960a4e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (99f9eb8ddcc7e57c5b6f92085626bae6) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 1c0cf821cea290aee1912d67df95738f.
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (11/16) (7450b381ae0a21cd5f1b75090ed61792) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (11/16) (7450b381ae0a21cd5f1b75090ed61792).
    [ToKeyedWorkItem (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (11/16) (7450b381ae0a21cd5f1b75090ed61792) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (11/16) (1c0cf821cea290aee1912d67df95738f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 7450b381ae0a21cd5f1b75090ed61792.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16) (92dbbc9749d70cc59156779c1ac4f6a8) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16) (92dbbc9749d70cc59156779c1ac4f6a8).
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16) (92dbbc9749d70cc59156779c1ac4f6a8) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (7450b381ae0a21cd5f1b75090ed61792) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 92dbbc9749d70cc59156779c1ac4f6a8.
    [ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (10/16) (d8aa677da51f15f79d9242f61719a4d2) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (10/16) (d8aa677da51f15f79d9242f61719a4d2).
    [ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16) (d8aa677da51f15f79d9242f61719a4d2) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16) (92dbbc9749d70cc59156779c1ac4f6a8) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem d8aa677da51f15f79d9242f61719a4d2.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (10/16) (d8aa677da51f15f79d9242f61719a4d2) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16) (01d2b4154adc3bda4ff24d8ac6664334) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16) (01d2b4154adc3bda4ff24d8ac6664334).
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16) (01d2b4154adc3bda4ff24d8ac6664334) [FINISHED]
    [ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (8/16) (1acf153ee52e5b33d600817c4c9f86db) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (8/16) (1acf153ee52e5b33d600817c4c9f86db).
    [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$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 01d2b4154adc3bda4ff24d8ac6664334.
    [ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16) (1acf153ee52e5b33d600817c4c9f86db) [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 1acf153ee52e5b33d600817c4c9f86db.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16) (afb48771097e60c08c5a47ef4c379d67) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16) (afb48771097e60c08c5a47ef4c379d67).
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16) (afb48771097e60c08c5a47ef4c379d67) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16) (01d2b4154adc3bda4ff24d8ac6664334) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (1acf153ee52e5b33d600817c4c9f86db) 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 PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} afb48771097e60c08c5a47ef4c379d67.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (12/16) (30b9e35c21a6fd744cfad739fb87dbfb) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (12/16) (30b9e35c21a6fd744cfad739fb87dbfb).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16) (afb48771097e60c08c5a47ef4c379d67) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16) (30b9e35c21a6fd744cfad739fb87dbfb) [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 30b9e35c21a6fd744cfad739fb87dbfb.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (30b9e35c21a6fd744cfad739fb87dbfb) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16) (e64972882abaf872bca5dc59cbb54bca) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16) (e64972882abaf872bca5dc59cbb54bca).
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16) (e64972882abaf872bca5dc59cbb54bca) [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$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} e64972882abaf872bca5dc59cbb54bca.
    [ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (5/16) (4236535ef7d8773f7f632e4bda0943e0) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (5/16) (4236535ef7d8773f7f632e4bda0943e0).
    [ToKeyedWorkItem (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (5/16) (4236535ef7d8773f7f632e4bda0943e0) [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 4236535ef7d8773f7f632e4bda0943e0.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (5/16) (e64972882abaf872bca5dc59cbb54bca) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (4236535ef7d8773f7f632e4bda0943e0) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16) (a38ee92483689e97e8a17c09187d23b0) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16) (a38ee92483689e97e8a17c09187d23b0).
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16) (a38ee92483689e97e8a17c09187d23b0) [FINISHED]
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16) (abbe5c211a00c56d1041a44a53c00bee) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16) (abbe5c211a00c56d1041a44a53c00bee).
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16) (abbe5c211a00c56d1041a44a53c00bee) [FINISHED]
    [ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (6/16) (6a80f8d7f46c6a9400e5bb5a6c8f40fa) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (6/16) (6a80f8d7f46c6a9400e5bb5a6c8f40fa).
    [ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) (6a80f8d7f46c6a9400e5bb5a6c8f40fa) [FINISHED]
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/16) (fd51f1b482491d213daa45d8cb915fb1) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/16) (fd51f1b482491d213daa45d8cb915fb1).
    [ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16) (fd51f1b482491d213daa45d8cb915fb1) [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$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} a38ee92483689e97e8a17c09187d23b0.
    [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$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} abbe5c211a00c56d1041a44a53c00bee.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16) (a3edb8eaebbc1df5e7baf02960f16a20) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16) (a3edb8eaebbc1df5e7baf02960f16a20).
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16) (a3edb8eaebbc1df5e7baf02960f16a20) [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 6a80f8d7f46c6a9400e5bb5a6c8f40fa.
    [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 fd51f1b482491d213daa45d8cb915fb1.
    [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$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} a3edb8eaebbc1df5e7baf02960f16a20.
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (121a6852da378ce071419c77a9ca069d) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (121a6852da378ce071419c77a9ca069d).
    [ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (121a6852da378ce071419c77a9ca069d) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16) (a38ee92483689e97e8a17c09187d23b0) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16) (abbe5c211a00c56d1041a44a53c00bee) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (6a80f8d7f46c6a9400e5bb5a6c8f40fa) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (fd51f1b482491d213daa45d8cb915fb1) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16) (a3edb8eaebbc1df5e7baf02960f16a20) 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 121a6852da378ce071419c77a9ca069d.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (121a6852da378ce071419c77a9ca069d) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (2f562c0461cdf1f473a715b71f1a5bb7) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (2f562c0461cdf1f473a715b71f1a5bb7).
    [PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (2f562c0461cdf1f473a715b71f1a5bb7) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 2f562c0461cdf1f473a715b71f1a5bb7.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$65/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (2f562c0461cdf1f473a715b71f1a5bb7) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (872dc7a9f4ba89b02cc51a9c7d0edf46) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (872dc7a9f4ba89b02cc51a9c7d0edf46).
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (872dc7a9f4ba89b02cc51a9c7d0edf46) [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 872dc7a9f4ba89b02cc51a9c7d0edf46.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (872dc7a9f4ba89b02cc51a9c7d0edf46) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] WARN org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a Metric with the name 'beam.metric:user:org.apache.beam.sdk.testing.PAssert:PAssertSuccess'. Metric will not be reported.[localhost, taskmanager, 9bfdf622-65c3-4eeb-93c3-5c183995ab6e, combinetest0basictests0testbasiccombine-jenkins-0104172218-7dfb4c31, [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}, 3]
    [PAssert$66/GroupGlobally/GroupDummyAndContents -> [5]PAssert$66/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$66/GroupGlobally/GroupDummyAndContents -> [5]PAssert$66/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (0133b863e225884f9737f3a3ec4e7f4e) switched from RUNNING to FINISHED.
    [PAssert$66/GroupGlobally/GroupDummyAndContents -> [5]PAssert$66/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$66/GroupGlobally/GroupDummyAndContents -> [5]PAssert$66/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (0133b863e225884f9737f3a3ec4e7f4e).
    [PAssert$66/GroupGlobally/GroupDummyAndContents -> [5]PAssert$66/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$66/GroupGlobally/GroupDummyAndContents -> [5]PAssert$66/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (0133b863e225884f9737f3a3ec4e7f4e) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$66/GroupGlobally/GroupDummyAndContents -> [5]PAssert$66/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 0133b863e225884f9737f3a3ec4e7f4e.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$66/GroupGlobally/GroupDummyAndContents -> [5]PAssert$66/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (0133b863e225884f9737f3a3ec4e7f4e) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (7b42cb40d7c110ff58e21c30eb355490) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (7b42cb40d7c110ff58e21c30eb355490).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (7b42cb40d7c110ff58e21c30eb355490) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 7b42cb40d7c110ff58e21c30eb355490.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (7b42cb40d7c110ff58e21c30eb355490) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (25acb4eae3a0b266a8dacb0782cc1f35) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (25acb4eae3a0b266a8dacb0782cc1f35).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (25acb4eae3a0b266a8dacb0782cc1f35) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 25acb4eae3a0b266a8dacb0782cc1f35.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (25acb4eae3a0b266a8dacb0782cc1f35) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (8d2ed224e38aac78ee1b64f213fd81c7) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (8d2ed224e38aac78ee1b64f213fd81c7).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (8d2ed224e38aac78ee1b64f213fd81c7) [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$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 8d2ed224e38aac78ee1b64f213fd81c7.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (8d2ed224e38aac78ee1b64f213fd81c7) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (0e4b6389ed21f40fa5398bbe8cb186a1) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (0e4b6389ed21f40fa5398bbe8cb186a1).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (0e4b6389ed21f40fa5398bbe8cb186a1) [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$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 0e4b6389ed21f40fa5398bbe8cb186a1.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (0e4b6389ed21f40fa5398bbe8cb186a1) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (f5b381c89aecaf610105753efdb873be) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (f5b381c89aecaf610105753efdb873be).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (f5b381c89aecaf610105753efdb873be) [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$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} f5b381c89aecaf610105753efdb873be.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (163b4e5b052ee458b674facff16a86ef) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (163b4e5b052ee458b674facff16a86ef).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (163b4e5b052ee458b674facff16a86ef) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (f5b381c89aecaf610105753efdb873be) 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$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 163b4e5b052ee458b674facff16a86ef.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (163b4e5b052ee458b674facff16a86ef) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (edb8b86fa3d07044fbacf1b595159be7) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (edb8b86fa3d07044fbacf1b595159be7).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (edb8b86fa3d07044fbacf1b595159be7) [FINISHED]
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (1a79802b704a07b922323f9509e773f7) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (1a79802b704a07b922323f9509e773f7).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (1a79802b704a07b922323f9509e773f7) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} edb8b86fa3d07044fbacf1b595159be7.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 1a79802b704a07b922323f9509e773f7.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (edb8b86fa3d07044fbacf1b595159be7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (1a79802b704a07b922323f9509e773f7) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (71854755006faab286a6713658525c6d) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (71854755006faab286a6713658525c6d).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (71854755006faab286a6713658525c6d) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 71854755006faab286a6713658525c6d.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (71854755006faab286a6713658525c6d) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (e98233a6d14a1a9265088f3a54848d86) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (e98233a6d14a1a9265088f3a54848d86).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (e98233a6d14a1a9265088f3a54848d86) [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$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} e98233a6d14a1a9265088f3a54848d86.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (e98233a6d14a1a9265088f3a54848d86) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (4b5390983cf8715a06f22e069b12d08c) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (4b5390983cf8715a06f22e069b12d08c).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (4b5390983cf8715a06f22e069b12d08c) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 4b5390983cf8715a06f22e069b12d08c.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (4b5390983cf8715a06f22e069b12d08c) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (b14cb23e56f79ae1a4c6a2acff5900d3) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (b14cb23e56f79ae1a4c6a2acff5900d3).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (b14cb23e56f79ae1a4c6a2acff5900d3) [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$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} b14cb23e56f79ae1a4c6a2acff5900d3.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (b14cb23e56f79ae1a4c6a2acff5900d3) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (1ee4bd0f76dfc7a8808e10525a98283c) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (1ee4bd0f76dfc7a8808e10525a98283c).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (1ee4bd0f76dfc7a8808e10525a98283c) [FINISHED]
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 1ee4bd0f76dfc7a8808e10525a98283c.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (1ee4bd0f76dfc7a8808e10525a98283c) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (e87adb1f216f7b1c5e22e1bacf354cbc) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (e87adb1f216f7b1c5e22e1bacf354cbc).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (e87adb1f216f7b1c5e22e1bacf354cbc) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} e87adb1f216f7b1c5e22e1bacf354cbc.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (e87adb1f216f7b1c5e22e1bacf354cbc) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (877428e415c52be984b4ce16810000ec) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (877428e415c52be984b4ce16810000ec).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (877428e415c52be984b4ce16810000ec) [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$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 877428e415c52be984b4ce16810000ec.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (877428e415c52be984b4ce16810000ec) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (d7f3f651403a9ed925db74e9ff48168b) switched from RUNNING to FINISHED.
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (d7f3f651403a9ed925db74e9ff48168b).
    [PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (d7f3f651403a9ed925db74e9ff48168b) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} d7f3f651403a9ed925db74e9ff48168b.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$65/GroupGlobally/GroupDummyAndContents -> [5]PAssert$65/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (d7f3f651403a9ed925db74e9ff48168b) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job combinetest0basictests0testbasiccombine-jenkins-0104172218-7dfb4c31 (aa4437db7a28cfc15b8781c7e5b8b5ae) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job aa4437db7a28cfc15b8781c7e5b8b5ae.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job aa4437db7a28cfc15b8781c7e5b8b5ae reached globally terminal state FINISHED.
    [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.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_126.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatchercccb753f-166a-473b-aa74-4f2a1e37eeac.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatchercccb753f-166a-473b-aa74-4f2a1e37eeac.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job combinetest0basictests0testbasiccombine-jenkins-0104172218-7dfb4c31(aa4437db7a28cfc15b8781c7e5b8b5ae).
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 40de6d3412e8fd15790ce2e1dc808607: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcActor - The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet. Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is started.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job aa4437db7a28cfc15b8781c7e5b8b5ae with leader id aadad434f231b370d0073761039a4577 lost leadership.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatchercccb753f-166a-473b-aa74-4f2a1e37eeac.
    [ForkJoinPool.commonPool-worker-8] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-8] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
    [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-9f43c7fa-54a2-43de-b889-7c2f329b437f
    [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_126.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:40105
    [flink-akka.actor.default-dispatcher-8] 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 18392 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@4928c028
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/combinetest0basictests0testbasiccombine-jenkins-0104172218-7dfb4c31_bd3bd8d5-1c74-47df-9683-9a8558f2de67/MANIFEST has 186 artifact locations
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/combinetest0basictests0testbasiccombine-jenkins-0104172218-7dfb4c31_bd3bd8d5-1c74-47df-9683-9a8558f2de67/

org.apache.beam.sdk.transforms.CombineTest$BasicTests > testBasicCombine SKIPPED

138 tests completed, 8 failed, 3 skipped

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

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 137
  This problem might be caused by incorrect test process configuration.
  Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.3/userguide/java_plugin.html#sec:test_execution

* 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.3/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 32m 21s
75 actionable tasks: 71 executed, 3 from cache, 1 up-to-date

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

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 #349

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/349/display/redirect>

------------------------------------------
[...truncated 239.11 MB...]
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (4ce9c874fda5450567c8237866dbe22e).
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (4ce9c874fda5450567c8237866dbe22e) [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 4ce9c874fda5450567c8237866dbe22e.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (20d2f63e70e4a676c193f8d483e3b471) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (4ce9c874fda5450567c8237866dbe22e) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] WARN org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a Metric with the name 'beam.metric:user:org.apache.beam.sdk.testing.PAssert:PAssertSuccess'. Metric will not be reported.[localhost, taskmanager, 4fb9ac9f-bcc7-4520-901e-a4ceaaae3889, reifytimestampstest0invaluessucceeds-jenkins-0104185417-b15ba35e, [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}, 3]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (ef872cc5839cd449209f3749da82a5c9) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (29c22e410d9dfd87d6a0e3fc20541835) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (ef872cc5839cd449209f3749da82a5c9).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (93d2bfce5cc8e7ab88ec5134d04b721e) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (93d2bfce5cc8e7ab88ec5134d04b721e).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (29c22e410d9dfd87d6a0e3fc20541835).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (ef872cc5839cd449209f3749da82a5c9) [FINISHED]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (93d2bfce5cc8e7ab88ec5134d04b721e) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} ef872cc5839cd449209f3749da82a5c9.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (29c22e410d9dfd87d6a0e3fc20541835) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 93d2bfce5cc8e7ab88ec5134d04b721e.
    [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 29c22e410d9dfd87d6a0e3fc20541835.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (ef872cc5839cd449209f3749da82a5c9) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (e87be8020efc22913b0ef42245391089) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (e87be8020efc22913b0ef42245391089).
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (93d2bfce5cc8e7ab88ec5134d04b721e) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (e87be8020efc22913b0ef42245391089) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} e87be8020efc22913b0ef42245391089.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (a05631b420d0f063a1b0ddcd04b54ab5) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (a05631b420d0f063a1b0ddcd04b54ab5).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (a05631b420d0f063a1b0ddcd04b54ab5) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (29c22e410d9dfd87d6a0e3fc20541835) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} a05631b420d0f063a1b0ddcd04b54ab5.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (d2de6b7f7a1fcf3369c3d7548b885d80) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (d2de6b7f7a1fcf3369c3d7548b885d80).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (d2de6b7f7a1fcf3369c3d7548b885d80) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} d2de6b7f7a1fcf3369c3d7548b885d80.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (e87be8020efc22913b0ef42245391089) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (a05631b420d0f063a1b0ddcd04b54ab5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (d2de6b7f7a1fcf3369c3d7548b885d80) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (5c88ffb132d76ed0ddf60e12219b96c1) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (5c88ffb132d76ed0ddf60e12219b96c1).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (5c88ffb132d76ed0ddf60e12219b96c1) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 5c88ffb132d76ed0ddf60e12219b96c1.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (586e37ce1e7e4681d024e8851173b612) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (586e37ce1e7e4681d024e8851173b612).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (586e37ce1e7e4681d024e8851173b612) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 586e37ce1e7e4681d024e8851173b612.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (5c88ffb132d76ed0ddf60e12219b96c1) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (586e37ce1e7e4681d024e8851173b612) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (202d3ac52f37b14215b3de5abc6b61da) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (202d3ac52f37b14215b3de5abc6b61da).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (202d3ac52f37b14215b3de5abc6b61da) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 202d3ac52f37b14215b3de5abc6b61da.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (202d3ac52f37b14215b3de5abc6b61da) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (73a454576dfc7543f90bd2f02e26007e) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (73a454576dfc7543f90bd2f02e26007e).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (73a454576dfc7543f90bd2f02e26007e) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 73a454576dfc7543f90bd2f02e26007e.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (73a454576dfc7543f90bd2f02e26007e) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (a7dcee862e96b25db9496b4cf0f5e6dc) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (a7dcee862e96b25db9496b4cf0f5e6dc).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (a7dcee862e96b25db9496b4cf0f5e6dc) [FINISHED]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (a62d4a0e3980aae1382b423f7646f02d) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} a7dcee862e96b25db9496b4cf0f5e6dc.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (a62d4a0e3980aae1382b423f7646f02d).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (a62d4a0e3980aae1382b423f7646f02d) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} a62d4a0e3980aae1382b423f7646f02d.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (a7dcee862e96b25db9496b4cf0f5e6dc) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (a62d4a0e3980aae1382b423f7646f02d) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (71a229dd9da2756c6f0a94355c1f2407) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (71a229dd9da2756c6f0a94355c1f2407).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (71a229dd9da2756c6f0a94355c1f2407) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 71a229dd9da2756c6f0a94355c1f2407.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (71a229dd9da2756c6f0a94355c1f2407) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (92b1482611f76004e55a29b3cd158817) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (92b1482611f76004e55a29b3cd158817).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (92b1482611f76004e55a29b3cd158817) [FINISHED]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (17c3c7b83d6c2122cf7ae4ca11182852) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (17c3c7b83d6c2122cf7ae4ca11182852).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (17c3c7b83d6c2122cf7ae4ca11182852) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 92b1482611f76004e55a29b3cd158817.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 17c3c7b83d6c2122cf7ae4ca11182852.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (92b1482611f76004e55a29b3cd158817) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (17c3c7b83d6c2122cf7ae4ca11182852) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (ffa53015ca12353c4aa7e422cc43be6f) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (ffa53015ca12353c4aa7e422cc43be6f).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (ffa53015ca12353c4aa7e422cc43be6f) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} ffa53015ca12353c4aa7e422cc43be6f.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (ffa53015ca12353c4aa7e422cc43be6f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-0104185417-b15ba35e (2fb4324f1d75c2569dc26dc98eb0cac1) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 2fb4324f1d75c2569dc26dc98eb0cac1.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 2fb4324f1d75c2569dc26dc98eb0cac1 reached globally terminal state FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-0104185417-b15ba35e(2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 2fb4324f1d75c2569dc26dc98eb0cac1.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 45a7ac073ba4cd7481ac92293cae2d18: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 842f426969ba77f36175e17cb8ba418b@akka://flink/user/jobmanager_231 for job 2fb4324f1d75c2569dc26dc98eb0cac1 from the resource manager.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
    [flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher7750736c-47a1-4da3-9c5d-7c4abd214f57.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher7750736c-47a1-4da3-9c5d-7c4abd214f57.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 2fb4324f1d75c2569dc26dc98eb0cac1 with leader id 842f426969ba77f36175e17cb8ba418b lost leadership.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-6] 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{4f65d7664b8a933868741bac41b7414f}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{f7e87f58935ddaa1749c032a4966d72d}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{436b9994a54ec5d717921dd8e516461e}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{a9401b030a52a349b01a8316a85c9d1d}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{5eadcec7f6ec0136bef567ec041d2690}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{b15ecbcf6043f0858c8a404552ab6d4a}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{5432b1b60e4923f280a8b40cdf69018a}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{13a53023c58bc2a24aa5bb978d45f41e}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{958ab9ad61d7fb3eb1705e985fffb9c1}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{965a1e2ca33d33fb2ccfd58611907bd4}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{30bdd4b82b4c3eb99520497f6216e019}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{d8c391512b70363dd940b8023b24f014}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{b40c9576cfa959e678318822db815c8d}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-6] 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{7905dd7e14d89392c0d99bffbb6dc5bb}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-4] 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{9a10209bd1512fea418f0cd72ce61ba0}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-4] 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{f00097398af68766e900235779e02451}, jobId: 2fb4324f1d75c2569dc26dc98eb0cac1).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 2fb4324f1d75c2569dc26dc98eb0cac1 from job leader monitoring.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 2fb4324f1d75c2569dc26dc98eb0cac1.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_230.
    [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-d6505c9e-0f8b-4fdf-99e6-59cab79b2332
    [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-7] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher7750736c-47a1-4da3-9c5d-7c4abd214f57.
    [ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
    [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_230.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:40417
    [flink-akka.actor.default-dispatcher-3] 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 9456 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@d0ccbb8b
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-0104185417-b15ba35e_92b49b31-00ad-4c74-b4c0-4acba3e6e906/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-0104185417-b15ba35e_92b49b31-00ad-4c74-b4c0-4acba3e6e906/
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:40445
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:33629

org.apache.beam.sdk.io.AvroIOTest$NeedsRunnerTests STANDARD_ERROR
    [grpc-default-executor-264] ERROR org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Failed to handle for unknown endpoint
    org.apache.beam.vendor.grpc.v1p13p1.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close
    [grpc-default-executor-285] WARN org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client failed unexpectedly.
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:272)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    org.apache.beam.vendor.grpc.v1p13p1.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:272)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    [grpc-default-executor-285] WARN org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client failed to be complete.
    org.apache.beam.vendor.grpc.v1p13p1.io.grpc.StatusRuntimeException: CANCELLED: call already cancelled
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
    	at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.completeIfNotNull(GrpcLoggingService.java:78)
    	at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.access$400(GrpcLoggingService.java:33)
    	at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService$InboundObserver.onError(GrpcLoggingService.java:105)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    Jan 04, 2019 6:54:38 PM org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor run
    SEVERE: Exception while executing runnable org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed@3776e62d
    org.apache.beam.vendor.grpc.v1p13p1.io.grpc.StatusRuntimeException: CANCELLED: call already cancelled
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
    	at org.apache.beam.runners.fnexecution.state.GrpcStateService$Inbound.onError(GrpcStateService.java:145)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)


Gradle Test Executor 2 finished executing tests.

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

196 tests completed, 5 failed, 2 skipped
Finished generating test XML results (2.612 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.982 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 3,5,main]) completed. Took 45 mins 56.334 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.3/userguide/command_line_interface.html#sec:command_line_warnings

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

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

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 #348

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/348/display/redirect?page=changes>

Changes:

[gleb] [BEAM-6367] Fix JdbcDriver breaking DriverManager#getConnection

------------------------------------------
[...truncated 233.00 MB...]
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (eb53acab8a78acb9a12600cea45cccda) switched from RUNNING to FINISHED.
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (eb53acab8a78acb9a12600cea45cccda).
    [ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (eb53acab8a78acb9a12600cea45cccda) [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 eb53acab8a78acb9a12600cea45cccda.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (54d4cb36a03b1489c8445bffd2222890) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (eb53acab8a78acb9a12600cea45cccda) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] WARN org.apache.flink.metrics.MetricGroup - Name collision: Group already contains a Metric with the name 'beam.metric:user:org.apache.beam.sdk.testing.PAssert:PAssertSuccess'. Metric will not be reported.[localhost, taskmanager, 6df0bf49-6342-46ab-bd0a-d3318a8bd260, reifytimestampstest0invaluessucceeds-jenkins-0104180459-ad76d103, [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}, 3]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (cb764e203d6e7e5c8118b3587f0fe516) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (cb764e203d6e7e5c8118b3587f0fe516).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (cb764e203d6e7e5c8118b3587f0fe516) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} cb764e203d6e7e5c8118b3587f0fe516.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (d3c54907382376ae57679c9e7d08f33c) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (d3c54907382376ae57679c9e7d08f33c).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (d3c54907382376ae57679c9e7d08f33c) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} d3c54907382376ae57679c9e7d08f33c.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (2a6d59beaff99185e14efdc9458c2750) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (2a6d59beaff99185e14efdc9458c2750).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (2a6d59beaff99185e14efdc9458c2750) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 2a6d59beaff99185e14efdc9458c2750.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (c281cb113488ac7243bf6abe62701c1d) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (c281cb113488ac7243bf6abe62701c1d).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (42a079ca2755ccb18d3e309ccc0bc921) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (42a079ca2755ccb18d3e309ccc0bc921).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (c281cb113488ac7243bf6abe62701c1d) [FINISHED]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (de9df1b7c284d5a17c9929e8a290c271) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (42a079ca2755ccb18d3e309ccc0bc921) [FINISHED]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (de9df1b7c284d5a17c9929e8a290c271).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (de9df1b7c284d5a17c9929e8a290c271) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (cb764e203d6e7e5c8118b3587f0fe516) 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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 42a079ca2755ccb18d3e309ccc0bc921.
    [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} c281cb113488ac7243bf6abe62701c1d.
    [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} de9df1b7c284d5a17c9929e8a290c271.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (d3c54907382376ae57679c9e7d08f33c) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (c9491578bd20afe723229334f6b5eda7) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (c9491578bd20afe723229334f6b5eda7).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (c9491578bd20afe723229334f6b5eda7) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} c9491578bd20afe723229334f6b5eda7.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (b66945c58561c13c3f4202943c25d77a) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (b66945c58561c13c3f4202943c25d77a).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (b66945c58561c13c3f4202943c25d77a) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} b66945c58561c13c3f4202943c25d77a.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (2a6d59beaff99185e14efdc9458c2750) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (107b8c37dab43b2199a01bbbc147a32a) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (107b8c37dab43b2199a01bbbc147a32a).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (107b8c37dab43b2199a01bbbc147a32a) [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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 107b8c37dab43b2199a01bbbc147a32a.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (42a079ca2755ccb18d3e309ccc0bc921) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (f5dceb5cb3238815e55b34f485be1fc7) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (f5dceb5cb3238815e55b34f485be1fc7).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (f5dceb5cb3238815e55b34f485be1fc7) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (c281cb113488ac7243bf6abe62701c1d) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (13181ce09c1a0de0c76770ab6dd7c1c8) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (13181ce09c1a0de0c76770ab6dd7c1c8).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} f5dceb5cb3238815e55b34f485be1fc7.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (13181ce09c1a0de0c76770ab6dd7c1c8) [FINISHED]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (924184869f8a04c8bd4df98c49b2a463) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (924184869f8a04c8bd4df98c49b2a463).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (924184869f8a04c8bd4df98c49b2a463) [FINISHED]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (8956cb5195253b67872ac9170e705472) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (412638e77fefd04e82f3d12271030c34) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (412638e77fefd04e82f3d12271030c34).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (8956cb5195253b67872ac9170e705472).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (412638e77fefd04e82f3d12271030c34) [FINISHED]
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (8956cb5195253b67872ac9170e705472) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 13181ce09c1a0de0c76770ab6dd7c1c8.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (de9df1b7c284d5a17c9929e8a290c271) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 924184869f8a04c8bd4df98c49b2a463.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 412638e77fefd04e82f3d12271030c34.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (c9491578bd20afe723229334f6b5eda7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 8956cb5195253b67872ac9170e705472.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (c39654a46500116e23baf9abf2e018a1) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (c39654a46500116e23baf9abf2e018a1).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (c39654a46500116e23baf9abf2e018a1) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (b66945c58561c13c3f4202943c25d77a) 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$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} c39654a46500116e23baf9abf2e018a1.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (107b8c37dab43b2199a01bbbc147a32a) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (f5dceb5cb3238815e55b34f485be1fc7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (13181ce09c1a0de0c76770ab6dd7c1c8) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (924184869f8a04c8bd4df98c49b2a463) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (412638e77fefd04e82f3d12271030c34) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (8956cb5195253b67872ac9170e705472) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (c39654a46500116e23baf9abf2e018a1) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (6f3d90e5833f8d74511709760222b002) switched from RUNNING to FINISHED.
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (6f3d90e5833f8d74511709760222b002).
    [PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (6f3d90e5833f8d74511709760222b002) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 6f3d90e5833f8d74511709760222b002.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (6f3d90e5833f8d74511709760222b002) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-0104180459-ad76d103 (5193120f2f8264643e6f2458f4a794ae) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 5193120f2f8264643e6f2458f4a794ae.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 5193120f2f8264643e6f2458f4a794ae reached globally terminal state FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-0104180459-ad76d103(5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 5193120f2f8264643e6f2458f4a794ae.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 8764f3197bdc4e99375ace94dfe44e66: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager bbc7641cbb5252f0b0fa8491f8e34ee6@akka://flink/user/jobmanager_231 for job 5193120f2f8264643e6f2458f4a794ae from the resource manager.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
    [flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher53e9125a-adb6-4be2-a3b2-ef6071b83fb7.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher53e9125a-adb6-4be2-a3b2-ef6071b83fb7.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 5193120f2f8264643e6f2458f4a794ae with leader id bbc7641cbb5252f0b0fa8491f8e34ee6 lost leadership.
    [flink-akka.actor.default-dispatcher-6] 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{8bf605b8086f6dbf7a5ec3adfdc93e9d}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.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{b20828661a16262c0148bb9184b82007}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{699a6e1968294da281c211617f299850}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{ca55a2eea1ad990ff793a598e7adaee4}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{5193c7e6e9cfe1dde096deaf9e68a383}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{7f6a4007b257f42bf1d3d01c46b5b150}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{da7483d84193ee18431766c4af8b88e6}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{50bd2396b3dc15cd76b0e816b62af767}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{f344756dfbe8fd1f98a64f0988026f28}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.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{2c2fa248f3e4d8ae7f3dc1e853d9cc2f}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher53e9125a-adb6-4be2-a3b2-ef6071b83fb7.
    [flink-akka.actor.default-dispatcher-6] 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{2c40ff886a419ad04a308a725d3e2f63}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{d92063cff5c9be926b94338cfe50dc26}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{940e267cb5710f218c2863b3434af473}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{853145b3d5192df13c4281bc968d389f}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{4c7ed4b0e2dee1b33cc315f08a42a2be}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] 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{531d7bca9af636f326a2d902d89ebf91}, jobId: 5193120f2f8264643e6f2458f4a794ae).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 5193120f2f8264643e6f2458f4a794ae from job leader monitoring.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 5193120f2f8264643e6f2458f4a794ae.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_230.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-daac4f12-1401-449c-948b-831909592fe0
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_230.
    [ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
    [ForkJoinPool.commonPool-worker-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:45053
    [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 6131 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@9c02df96
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-0104180459-ad76d103_14d44a10-b204-4c4f-b805-29cbfb0c6a5a/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-0104180459-ad76d103_14d44a10-b204-4c4f-b805-29cbfb0c6a5a/
    [grpc-default-executor-116] WARN org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Logging client failed unexpectedly.
    [grpc-default-executor-90] ERROR org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer - Failed to handle for unknown endpoint
    org.apache.beam.vendor.grpc.v1p13p1.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:272)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    [grpc-default-executor-116] WARN org.apache.beam.runners.fnexecution.logging.GrpcLoggingService - Beam Fn Logging client failed to be complete.
    org.apache.beam.vendor.grpc.v1p13p1.io.grpc.StatusRuntimeException: CANCELLED: cancelled before receiving half close
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:272)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    org.apache.beam.vendor.grpc.v1p13p1.io.grpc.StatusRuntimeException: CANCELLED: call already cancelled
    Jan 04, 2019 6:05:08 PM org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor run
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
    	at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.completeIfNotNull(GrpcLoggingService.java:78)
    	at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService.access$400(GrpcLoggingService.java:33)
    	at org.apache.beam.runners.fnexecution.logging.GrpcLoggingService$InboundObserver.onError(GrpcLoggingService.java:105)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
    SEVERE: Exception while executing runnable org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed@4f8a4436
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    org.apache.beam.vendor.grpc.v1p13p1.io.grpc.StatusRuntimeException: CANCELLED: call already cancelled
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Status.asRuntimeException(Status.java:517)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$ServerCallStreamObserverImpl.onCompleted(ServerCalls.java:356)
    	at org.apache.beam.runners.fnexecution.state.GrpcStateService$Inbound.onError(GrpcStateService.java:145)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.stub.ServerCalls$StreamingServerCallHandler$StreamingServerCallListener.onCancel(ServerCalls.java:269)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.PartialForwardingServerCallListener.onCancel(PartialForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:23)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onCancel(ForwardingServerCallListener.java:40)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Contexts$ContextualizedServerCallListener.onCancel(Contexts.java:96)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:293)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:738)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
    	at org.apache.beam.vendor.grpc.v1p13p1.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    	at java.lang.Thread.run(Thread.java:748)

    [pool-20016-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:36335
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:33567

Gradle Test Executor 1 finished executing tests.

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

196 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.494 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (0.944 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 6,5,main]) completed. Took 37 mins 9.154 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.3/userguide/command_line_interface.html#sec:command_line_warnings

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

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

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