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 2018/12/21 12:40:34 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming
#253
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/253/display/redirect?page=changes>
Changes:
[iemejia] [BEAM-6212] Add MongoDbIO ordered option
------------------------------------------
[...truncated 233.00 MB...]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16) (e2d934d00f6c7a4ea7e2119ae57a8e2f) 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/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 5ec46cabdbfe21284b7734ecf9a2e7f3.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16) (8d118c0f7b1135ce028973754a2ca819) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16) (8d118c0f7b1135ce028973754a2ca819).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16) (bf1cecbe45115c8003b9feaaa6f92b93) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16) (bf1cecbe45115c8003b9feaaa6f92b93).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16) (8d118c0f7b1135ce028973754a2ca819) [FINISHED]
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (9/16) (b169f20d7430c7a14782bc42a7da9913) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (8/16) (12990f908a7251a6dbb1ab6b20e25d46) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (9/16) (b169f20d7430c7a14782bc42a7da9913).
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (8/16) (12990f908a7251a6dbb1ab6b20e25d46).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16) (5c1b8d8834c8b66a38251c9ce79c414a) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16) (bf1cecbe45115c8003b9feaaa6f92b93) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16) (5c1b8d8834c8b66a38251c9ce79c414a).
[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/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 8d118c0f7b1135ce028973754a2ca819.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (b169f20d7430c7a14782bc42a7da9913) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16) (5c1b8d8834c8b66a38251c9ce79c414a) [FINISHED]
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16) (12990f908a7251a6dbb1ab6b20e25d46) [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/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} bf1cecbe45115c8003b9feaaa6f92b93.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16) (b2c03a0ac41eee5b2d207b7e00afb548) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (12/16) (30d026859e264c1c63043cfa4b2b21d5) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (12/16) (30d026859e264c1c63043cfa4b2b21d5).
[ToKeyedWorkItem (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (12/16) (30d026859e264c1c63043cfa4b2b21d5) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem b169f20d7430c7a14782bc42a7da9913.
[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/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 5c1b8d8834c8b66a38251c9ce79c414a.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16) (02475909a1345703f7aa9071e23f2e53) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 12990f908a7251a6dbb1ab6b20e25d46.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 30d026859e264c1c63043cfa4b2b21d5.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16) (5ec46cabdbfe21284b7734ecf9a2e7f3) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (6/16) (714638d4f11ee9e9e7292de249b6769e) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (6/16) (714638d4f11ee9e9e7292de249b6769e).
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) (714638d4f11ee9e9e7292de249b6769e) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 714638d4f11ee9e9e7292de249b6769e.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (1/16) (8d118c0f7b1135ce028973754a2ca819) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16) (bf1cecbe45115c8003b9feaaa6f92b93) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (b169f20d7430c7a14782bc42a7da9913) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16) (5c1b8d8834c8b66a38251c9ce79c414a) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (13/16) (154468d9f608097cd40d98a406471d6d) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (13/16) (154468d9f608097cd40d98a406471d6d).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) (154468d9f608097cd40d98a406471d6d) [FINISHED]
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (1/16) (9d80491243476da20e34687aecb2e933) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (1/16) (9d80491243476da20e34687aecb2e933).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 154468d9f608097cd40d98a406471d6d.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16) (4ef1682f1dab51e0b8b7671726eb00a7) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16) (4ef1682f1dab51e0b8b7671726eb00a7).
[ToKeyedWorkItem (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (1/16) (9d80491243476da20e34687aecb2e933) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (12990f908a7251a6dbb1ab6b20e25d46) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (14/16) (ce5be5b856648b474b37298b79b02e7e) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (14/16) (ce5be5b856648b474b37298b79b02e7e).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16) (4ef1682f1dab51e0b8b7671726eb00a7) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 9d80491243476da20e34687aecb2e933.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (ce5be5b856648b474b37298b79b02e7e) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 4ef1682f1dab51e0b8b7671726eb00a7.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (30d026859e264c1c63043cfa4b2b21d5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (714638d4f11ee9e9e7292de249b6769e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem ce5be5b856648b474b37298b79b02e7e.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (154468d9f608097cd40d98a406471d6d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (9d80491243476da20e34687aecb2e933) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (7/16) (4ef1682f1dab51e0b8b7671726eb00a7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (ce5be5b856648b474b37298b79b02e7e) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (b70c521dc883dbc8f89dfd024ee5aada) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (b70c521dc883dbc8f89dfd024ee5aada).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (b70c521dc883dbc8f89dfd024ee5aada) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem b70c521dc883dbc8f89dfd024ee5aada.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (b70c521dc883dbc8f89dfd024ee5aada) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (736a90c578a65a2d2511af5ecd63ad6c) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (736a90c578a65a2d2511af5ecd63ad6c).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (736a90c578a65a2d2511af5ecd63ad6c) [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/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 736a90c578a65a2d2511af5ecd63ad6c.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (8fa428c72e221c2d53d86c555b275487) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (8fa428c72e221c2d53d86c555b275487).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (8fa428c72e221c2d53d86c555b275487) [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 8fa428c72e221c2d53d86c555b275487.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (736a90c578a65a2d2511af5ecd63ad6c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (8fa428c72e221c2d53d86c555b275487) 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, 69fcc9d9-afa7-4231-97e7-07135c89b6bc, reifytimestampstest0invaluessucceeds-jenkins-1221124000-5877e68f, [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}, 3]
[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) (b41ec2e6b7cf79e5cecffd7ef848073f) 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) (b41ec2e6b7cf79e5cecffd7ef848073f).
[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) (b41ec2e6b7cf79e5cecffd7ef848073f) [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} b41ec2e6b7cf79e5cecffd7ef848073f.
[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) (37584647c4ed4874483a15dc39f2e5ca) 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) (190cef52acca4de9bedeaed9f85fc705) 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) (37584647c4ed4874483a15dc39f2e5ca).
[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) (190cef52acca4de9bedeaed9f85fc705).
[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) (545eeffbed3acb06f645e6e6091b60ff) 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) (545eeffbed3acb06f645e6e6091b60ff).
[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) (37584647c4ed4874483a15dc39f2e5ca) [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) (190cef52acca4de9bedeaed9f85fc705) [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) (545eeffbed3acb06f645e6e6091b60ff) [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} 37584647c4ed4874483a15dc39f2e5ca.
[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} 190cef52acca4de9bedeaed9f85fc705.
[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} 545eeffbed3acb06f645e6e6091b60ff.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (16/16) (b41ec2e6b7cf79e5cecffd7ef848073f) 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) (d8178f9d0fe004d59e7e5225ab00831e) 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) (d8178f9d0fe004d59e7e5225ab00831e).
[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) (d8178f9d0fe004d59e7e5225ab00831e) [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) (7ddd2351b94d641f6c34bdab0fe8b8e1) 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) (7ddd2351b94d641f6c34bdab0fe8b8e1).
[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) (7ddd2351b94d641f6c34bdab0fe8b8e1) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} d8178f9d0fe004d59e7e5225ab00831e.
[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) (cc11d45812ed31ba8b89805236f1c62c) 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) (cc11d45812ed31ba8b89805236f1c62c).
[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) (cc11d45812ed31ba8b89805236f1c62c) [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} (8/16) (37584647c4ed4874483a15dc39f2e5ca) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 7ddd2351b94d641f6c34bdab0fe8b8e1.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} cc11d45812ed31ba8b89805236f1c62c.
[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) (190cef52acca4de9bedeaed9f85fc705) 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) (545eeffbed3acb06f645e6e6091b60ff) 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} (10/16) (d8178f9d0fe004d59e7e5225ab00831e) 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} (3/16) (7ddd2351b94d641f6c34bdab0fe8b8e1) 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) (4a3ab9ecc3a96ff7de5d15de9070f99d) 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) (4a3ab9ecc3a96ff7de5d15de9070f99d).
[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) (4a3ab9ecc3a96ff7de5d15de9070f99d) [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) (cc11d45812ed31ba8b89805236f1c62c) 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} 4a3ab9ecc3a96ff7de5d15de9070f99d.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (14/16) (4a3ab9ecc3a96ff7de5d15de9070f99d) 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 - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (744dc045538ea459f434777bb7dd03b9) 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) (744dc045538ea459f434777bb7dd03b9).
[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) (744dc045538ea459f434777bb7dd03b9) [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} 744dc045538ea459f434777bb7dd03b9.
[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) (7ae55bbcfbe3064b60182ee1b1eece19) 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) (7ae55bbcfbe3064b60182ee1b1eece19).
[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) (7ae55bbcfbe3064b60182ee1b1eece19) [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} 7ae55bbcfbe3064b60182ee1b1eece19.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (744dc045538ea459f434777bb7dd03b9) 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} (2/16) (7ae55bbcfbe3064b60182ee1b1eece19) 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) (555f78d410b8119238a8e51423aba404) 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) (555f78d410b8119238a8e51423aba404).
[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) (555f78d410b8119238a8e51423aba404) [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} 555f78d410b8119238a8e51423aba404.
[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) (7334d89d7fde89d4e986327f4fd8d990) 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) (7334d89d7fde89d4e986327f4fd8d990).
[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) (7334d89d7fde89d4e986327f4fd8d990) [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) (4bb37176844d58c42f04a8a957949228) 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) (4bb37176844d58c42f04a8a957949228).
[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) (4bb37176844d58c42f04a8a957949228) [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} 7334d89d7fde89d4e986327f4fd8d990.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (555f78d410b8119238a8e51423aba404) 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} 4bb37176844d58c42f04a8a957949228.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (7334d89d7fde89d4e986327f4fd8d990) 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) (dc0068206954d9c62ef6a8e496739786) 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) (dc0068206954d9c62ef6a8e496739786).
[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) (dc0068206954d9c62ef6a8e496739786) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} dc0068206954d9c62ef6a8e496739786.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (4bb37176844d58c42f04a8a957949228) 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) (05c03cd7b1c657b7fb797a77a5a8d90c) 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) (05c03cd7b1c657b7fb797a77a5a8d90c).
[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) (05c03cd7b1c657b7fb797a77a5a8d90c) [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} 05c03cd7b1c657b7fb797a77a5a8d90c.
[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) (dc0068206954d9c62ef6a8e496739786) 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} (15/16) (05c03cd7b1c657b7fb797a77a5a8d90c) 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) (20053a5c4471827a3f2ae7f70df0fa57) 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) (20053a5c4471827a3f2ae7f70df0fa57).
[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) (20053a5c4471827a3f2ae7f70df0fa57) [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} 20053a5c4471827a3f2ae7f70df0fa57.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (20053a5c4471827a3f2ae7f70df0fa57) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1221124000-5877e68f (cc3d36eac2d63b106148b070af291b5a) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job cc3d36eac2d63b106148b070af291b5a.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job cc3d36eac2d63b106148b070af291b5a reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1221124000-5877e68f(cc3d36eac2d63b106148b070af291b5a).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job cc3d36eac2d63b106148b070af291b5a.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection bbecf03375031610c42bef5a3e36ed08: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager a9cee48fcfecd62e8903b9afab8e48e6@akka://flink/user/jobmanager_231 for job cc3d36eac2d63b106148b070af291b5a from the resource manager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-7] 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 cc3d36eac2d63b106148b070af291b5a with leader id a9cee48fcfecd62e8903b9afab8e48e6 lost leadership.
[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{a9c8beb3fa5ef725201ccd775d7d0a2b}, jobId: cc3d36eac2d63b106148b070af291b5a).
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher7697f96b-3640-4250-bbc6-1e38c54bccb7.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher7697f96b-3640-4250-bbc6-1e38c54bccb7.
[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{1ba29b4302b71f438e7ddca896cba320}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{0f106958402b61549b9fb8df35681c39}, jobId: cc3d36eac2d63b106148b070af291b5a).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-7] 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:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{5b687904554aa443fadc58b599e19010}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{48fcb9bd0cbf7cde25084d561f706652}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{f7e64e02b485a2d01f63fd567279899a}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{6204ba6b4853bc843da207612ddb1504}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{79d9cc11dece6d64f042aa45894b1098}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{5f6846e01fc0b7a6ec4b516bd8fc72a3}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{31566855be11284ab6831286091ccc68}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{c996095129e0754f7b332c10f14a0cc5}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{59b2e136e2a46858d6cba59be4979a7e}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{da9d4a853cd541dd701bdd5a0b22b46e}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{3b7e5799cdb329a83abb6e344dad3673}, jobId: cc3d36eac2d63b106148b070af291b5a).
[flink-akka.actor.default-dispatcher-4] 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{d9a9347b8927182f32ad4e194d73ee28}, jobId: cc3d36eac2d63b106148b070af291b5a).
[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{32bd6512f4540ae1efbcfdaa34b0f781}, jobId: cc3d36eac2d63b106148b070af291b5a).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job cc3d36eac2d63b106148b070af291b5a from job leader monitoring.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job cc3d36eac2d63b106148b070af291b5a.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job cc3d36eac2d63b106148b070af291b5a.
[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-5] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher7697f96b-3640-4250-bbc6-1e38c54bccb7.
[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-6c96247f-bb20-4eee-b84a-173bdfe2a9a3
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-13] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[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-4] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:46459
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 10162 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@739e64f1
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1221124000-5877e68f_413e43dd-ecc6-424b-9c65-96df8fa797f8/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-1221124000-5877e68f_413e43dd-ecc6-424b-9c65-96df8fa797f8/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:38293
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:33433
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.478 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerStreaming>
Generating HTML test report...
Finished generating test html results (1.677 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 ':',5,main]) completed. Took 38 mins 27.645 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 40m 56s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/x3hbxsat2tk6g
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
#254
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/254/display/redirect>
------------------------------------------
[...truncated 233.03 MB...]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (8/16) (d1d46e1fda4b049e88f7bd01d3cea0fc) 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$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} e11e71a79654c70682a05c82891540f4.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (3/16) (083cc281cf56ba945580aeb40f5ecf33) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16) (bf4a234110ab422d90fdf8e340e92959) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16) (bf4a234110ab422d90fdf8e340e92959).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16) (bf4a234110ab422d90fdf8e340e92959) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16) (33b9764371030ea7a63ce92ebb92a3a1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} bf4a234110ab422d90fdf8e340e92959.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16) (33b9764371030ea7a63ce92ebb92a3a1).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16) (33b9764371030ea7a63ce92ebb92a3a1) [FINISHED]
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16) (5a1997d727ca7155ab9c2047411349e7) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16) (5a1997d727ca7155ab9c2047411349e7).
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (6/16) (c84bf4ea6dca4d7618ad51c2fbd41a90) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (6/16) (c84bf4ea6dca4d7618ad51c2fbd41a90).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16) (5a1997d727ca7155ab9c2047411349e7) [FINISHED]
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) (c84bf4ea6dca4d7618ad51c2fbd41a90) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (15/16) (b1403c4ac41e55400f21d0aa8d6db8f4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 33b9764371030ea7a63ce92ebb92a3a1.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (909b213a37f04b8e9c4e99d4643f1ac3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 5a1997d727ca7155ab9c2047411349e7.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (10/16) (5ea5b184faa8f1498e638dc3a27f66e7) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (10/16) (5ea5b184faa8f1498e638dc3a27f66e7).
[ToKeyedWorkItem (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (10/16) (5ea5b184faa8f1498e638dc3a27f66e7) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (12/16) (53205e2ba3a47cc1960a7caf3c6d265e) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (14/16) (183087ea014b674fc3153d1113cfe101) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (14/16) (183087ea014b674fc3153d1113cfe101).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (c5fd5415b48e618787140a2560320959) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (9/16) (98192df09f9bc291c3354b2f6a12473b) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (14/16) (183087ea014b674fc3153d1113cfe101) [FINISHED]
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (9/16) (98192df09f9bc291c3354b2f6a12473b).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem c84bf4ea6dca4d7618ad51c2fbd41a90.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (9fab92d6d07e3e486e6a812732904016) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (9/16) (98192df09f9bc291c3354b2f6a12473b) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 5ea5b184faa8f1498e638dc3a27f66e7.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 183087ea014b674fc3153d1113cfe101.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (342eec1f072a4cbb50c1c71671aa32aa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem 98192df09f9bc291c3354b2f6a12473b.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (f28bcedd0f443107e27c9150bb376b41) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16) (14fd4745f9da35d0e5b3b9d23d720d96) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16) (14fd4745f9da35d0e5b3b9d23d720d96).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16) (14fd4745f9da35d0e5b3b9d23d720d96) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 14fd4745f9da35d0e5b3b9d23d720d96.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (6/16) (e11e71a79654c70682a05c82891540f4) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16) (5cb05d272d427f6bd1f2a36c912fbbf7) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16) (5cb05d272d427f6bd1f2a36c912fbbf7).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16) (5cb05d272d427f6bd1f2a36c912fbbf7) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 5cb05d272d427f6bd1f2a36c912fbbf7.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (10/16) (bf4a234110ab422d90fdf8e340e92959) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (14/16) (33b9764371030ea7a63ce92ebb92a3a1) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (16/16) (a34f74a2c7c7882df8f3b192b66636b4) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (13/16) (f7411a2b4ec091e162b1bf61d8e6c145) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (13/16) (f7411a2b4ec091e162b1bf61d8e6c145).
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (16/16) (a34f74a2c7c7882df8f3b192b66636b4).
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) (f7411a2b4ec091e162b1bf61d8e6c145) [FINISHED]
[ToKeyedWorkItem (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (16/16) (a34f74a2c7c7882df8f3b192b66636b4) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (9/16) (5a1997d727ca7155ab9c2047411349e7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (c84bf4ea6dca4d7618ad51c2fbd41a90) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (10/16) (5ea5b184faa8f1498e638dc3a27f66e7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (183087ea014b674fc3153d1113cfe101) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (98192df09f9bc291c3354b2f6a12473b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (13/16) (14fd4745f9da35d0e5b3b9d23d720d96) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (16/16) (5cb05d272d427f6bd1f2a36c912fbbf7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task ToKeyedWorkItem f7411a2b4ec091e162b1bf61d8e6c145.
[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 a34f74a2c7c7882df8f3b192b66636b4.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (f7411a2b4ec091e162b1bf61d8e6c145) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (16/16) (a34f74a2c7c7882df8f3b192b66636b4) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (77a7c1711d1e49c9826420c67f69a4c9) switched from RUNNING to FINISHED.
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (77a7c1711d1e49c9826420c67f69a4c9).
[PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/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$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (77a7c1711d1e49c9826420c67f69a4c9) [FINISHED]
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (0e29020e86d4386edb2765c6433d4653) 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$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} 77a7c1711d1e49c9826420c67f69a4c9.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (0e29020e86d4386edb2765c6433d4653).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (0e29020e86d4386edb2765c6433d4653) [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 0e29020e86d4386edb2765c6433d4653.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GatherAllOutputs/GroupByKey -> [6]PAssert$132/GroupGlobally/{GatherAllOutputs, RewindowActuals, KeyForDummy, RemoveActualsTriggering, FlattenDummyAndContents, NeverTrigger} (2/16) (77a7c1711d1e49c9826420c67f69a4c9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (0e29020e86d4386edb2765c6433d4653) 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, f6ef944a-02ce-4f8e-af8e-609aa3862d56, reifytimestampstest0invaluessucceeds-jenkins-1221132055-c97dc35d, [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}, 3]
[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) (673281f636265a8880c9d53718db4c62) 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 - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (8db1fa8593c773a193d840b9776f2bcd) 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) (9b4c4bd514c4ed109f3209f791405d6f) 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) (8db1fa8593c773a193d840b9776f2bcd).
[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) (673281f636265a8880c9d53718db4c62).
[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) (9b4c4bd514c4ed109f3209f791405d6f).
[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) (c254c1cbf0f848b24e32f88e085a4686) 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) (c254c1cbf0f848b24e32f88e085a4686).
[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) (8db1fa8593c773a193d840b9776f2bcd) [FINISHED]
[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) (9b4c4bd514c4ed109f3209f791405d6f) [FINISHED]
[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) (c254c1cbf0f848b24e32f88e085a4686) [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) (7b58c5f55448b7bcc10ffd2403a26aee) 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) (7b58c5f55448b7bcc10ffd2403a26aee).
[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) (673281f636265a8880c9d53718db4c62) [FINISHED]
[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) (7b58c5f55448b7bcc10ffd2403a26aee) [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} 8db1fa8593c773a193d840b9776f2bcd.
[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} 9b4c4bd514c4ed109f3209f791405d6f.
[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} c254c1cbf0f848b24e32f88e085a4686.
[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} 673281f636265a8880c9d53718db4c62.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (8/16) (8db1fa8593c773a193d840b9776f2bcd) 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} 7b58c5f55448b7bcc10ffd2403a26aee.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (2/16) (9b4c4bd514c4ed109f3209f791405d6f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (11/16) (c254c1cbf0f848b24e32f88e085a4686) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (10/16) (673281f636265a8880c9d53718db4c62) 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 - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (d7f7f63159a7fb91cd71d6b06510f91e) 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) (d7f7f63159a7fb91cd71d6b06510f91e).
[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) (d7f7f63159a7fb91cd71d6b06510f91e) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (7/16) (7b58c5f55448b7bcc10ffd2403a26aee) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} d7f7f63159a7fb91cd71d6b06510f91e.
[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) (abca1061dd1ed719e1fb38d3ba60e0f2) 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) (abca1061dd1ed719e1fb38d3ba60e0f2).
[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) (abca1061dd1ed719e1fb38d3ba60e0f2) [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) (264cbd76a6cb0a133d96ccb174f144eb) 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) (264cbd76a6cb0a133d96ccb174f144eb).
[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) (264cbd76a6cb0a133d96ccb174f144eb) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} abca1061dd1ed719e1fb38d3ba60e0f2.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 264cbd76a6cb0a133d96ccb174f144eb.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (12/16) (d7f7f63159a7fb91cd71d6b06510f91e) 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) (09188fc5e170b94b5e56c4e00912404d) 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) (17f44b17e05e9268134d73242e4d5574) 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) (17f44b17e05e9268134d73242e4d5574).
[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) (09188fc5e170b94b5e56c4e00912404d).
[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) (17f44b17e05e9268134d73242e4d5574) [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) (20f0c5848dadf4cdbd275f30f8e50ae1) 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) (20f0c5848dadf4cdbd275f30f8e50ae1).
[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) (09188fc5e170b94b5e56c4e00912404d) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 17f44b17e05e9268134d73242e4d5574.
[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) (20f0c5848dadf4cdbd275f30f8e50ae1) [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) (d4bbe6fe345525d4b81caf361ff2befd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (9/16) (abca1061dd1ed719e1fb38d3ba60e0f2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 09188fc5e170b94b5e56c4e00912404d.
[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) (d4bbe6fe345525d4b81caf361ff2befd).
[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) (d4bbe6fe345525d4b81caf361ff2befd) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} 20f0c5848dadf4cdbd275f30f8e50ae1.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (3/16) (264cbd76a6cb0a133d96ccb174f144eb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} d4bbe6fe345525d4b81caf361ff2befd.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (13/16) (17f44b17e05e9268134d73242e4d5574) switched from RUNNING to FINISHED.
[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) (09188fc5e170b94b5e56c4e00912404d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (5/16) (20f0c5848dadf4cdbd275f30f8e50ae1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (6/16) (d4bbe6fe345525d4b81caf361ff2befd) 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) (dce82f1129df166785871ae0c043485c) 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) (dce82f1129df166785871ae0c043485c).
[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) (dce82f1129df166785871ae0c043485c) [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} dce82f1129df166785871ae0c043485c.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (1/16) (dce82f1129df166785871ae0c043485c) 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) (5108898df32f38b10ccd3c68adddfa3b) 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) (5108898df32f38b10ccd3c68adddfa3b).
[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) (5108898df32f38b10ccd3c68adddfa3b) [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} 5108898df32f38b10ccd3c68adddfa3b.
[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) (e9aefe3e2444751720f303e66ee039d4) 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) (e9aefe3e2444751720f303e66ee039d4).
[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) (e9aefe3e2444751720f303e66ee039d4) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (15/16) (5108898df32f38b10ccd3c68adddfa3b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} e9aefe3e2444751720f303e66ee039d4.
[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) (e9aefe3e2444751720f303e66ee039d4) 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) (aeb76c20dbbac6eefb88c6f37f6a3286) 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) (aeb76c20dbbac6eefb88c6f37f6a3286).
[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) (aeb76c20dbbac6eefb88c6f37f6a3286) [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} aeb76c20dbbac6eefb88c6f37f6a3286.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$132/GroupGlobally/GroupDummyAndContents -> [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions} (4/16) (aeb76c20dbbac6eefb88c6f37f6a3286) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1221132055-c97dc35d (e0b8da89ccc43c00207ec9662911e238) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job e0b8da89ccc43c00207ec9662911e238.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job e0b8da89ccc43c00207ec9662911e238 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1221132055-c97dc35d(e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job e0b8da89ccc43c00207ec9662911e238.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 102bdd21a8b3d9edb11a356a609f2e5d: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 91f7e166d0269506d284fac234ce4e18@akka://flink/user/jobmanager_231 for job e0b8da89ccc43c00207ec9662911e238 from the resource manager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job e0b8da89ccc43c00207ec9662911e238 with leader id 91f7e166d0269506d284fac234ce4e18 lost leadership.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher4f65f980-34ae-4113-832c-298de65204d6.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:4, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2bc1deab03f72e08975600f9e4bf34ea}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher4f65f980-34ae-4113-832c-298de65204d6.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:8, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{7e4a6b156a41affc8b43882759dd581b}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:9, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{6ad083c0d6087d95a68b2ccabe782b5f}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:11, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{da7ec5c68a3704554ac59bdd567acef7}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:13, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{c6f61c980433c06cf5aae51dfcdca90f}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:10, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{93ccc0cc9a411714af02d2762d8f08a3}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:7, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2c933014979fc4d707075dd7affcef17}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:6, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{f4184bc2f36c30d0c509e7700ce6e56e}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:0, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{4aac0a6a030c225dd7c5287f28f6f314}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:12, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{0cfc5e7b0d6fdd367daf9bbbda7cfa6d}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:1, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{c92fd24eb2344aa12e5d2422a434df85}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:5, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{e78823f46cad23966c37b739bd5a19e2}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:15, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{16d2fecb294d908860d589600085c24d}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{dc56f7b3b6d41da368810ee9476adff9}, jobId: e0b8da89ccc43c00207ec9662911e238).
[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{a975ab929125e3941c86dbda5f9a7b13}, jobId: e0b8da89ccc43c00207ec9662911e238).
[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{1f02f483ec22392d54cb9ef0268c600f}, jobId: e0b8da89ccc43c00207ec9662911e238).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job e0b8da89ccc43c00207ec9662911e238 from job leader monitoring.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job e0b8da89ccc43c00207ec9662911e238.
[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-bce0a97e-e849-4461-8f36-67cc78c97fdc
[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-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/dispatcher4f65f980-34ae-4113-832c-298de65204d6.
[ForkJoinPool.commonPool-worker-4] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[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.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:36907
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 7262 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@980bb209
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1221132055-c97dc35d_75dee165-a3a1-4b59-95ac-2af21479e3e4/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-1221132055-c97dc35d_75dee165-a3a1-4b59-95ac-2af21479e3e4/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:41299
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:36835
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming
197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (1.547 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.914 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[Daemon worker,5,main]) completed. Took 37 mins 51.996 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 40m 21s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/ry63kxvolczay
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