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/02 06:45:08 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Streaming
#74
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/74/display/redirect>
------------------------------------------
[...truncated 230.73 MB...]
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (13/16) (d2a4f4d310f8461c7c836293d9e02bfe).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (5/16) (2ccb6b4a51c5afa5a73f63ad1408f384) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (6/16) (25f99924de948849a3fe98e17122c079) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 56129cda05e0c83eb65c2f415659dcc9.
[ToKeyedWorkItem (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (13/16) (d2a4f4d310f8461c7c836293d9e02bfe) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (14/16) (65b6933c62445e0e788afc416e61f0ec) 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 bbce5884d491a85476cd9b1a1d3136cd.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (1/16) (a080253a32aa8e47460a6e2294782b1a) 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 0db8065f34b39c8b052bc6b4f696966b.
[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 75af1f76bb98ca0890ee4ac8af685678.
[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 bdf793c771dbd9f99bceec4051cdfda7.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (11/16) (56129cda05e0c83eb65c2f415659dcc9) 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 9916d982dafd22903d7effea8f7f2c50.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (9/16) (bbce5884d491a85476cd9b1a1d3136cd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 90f8a4c274d9d550a13a8d8f729adc85.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (10/16) (0db8065f34b39c8b052bc6b4f696966b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (12/16) (75af1f76bb98ca0890ee4ac8af685678) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (14/16) (bdf793c771dbd9f99bceec4051cdfda7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 6a2fe25a27937fe8a459636cc57f7623.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (11/16) (9916d982dafd22903d7effea8f7f2c50) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (13/16) (90f8a4c274d9d550a13a8d8f729adc85) 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 25f99924de948849a3fe98e17122c079.
[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 d2a4f4d310f8461c7c836293d9e02bfe.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (6/16) (6a2fe25a27937fe8a459636cc57f7623) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (9016656177e43ab185ca53220555b7d6) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (9016656177e43ab185ca53220555b7d6).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (6/16) (25f99924de948849a3fe98e17122c079) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (9016656177e43ab185ca53220555b7d6) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (13/16) (d2a4f4d310f8461c7c836293d9e02bfe) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 9016656177e43ab185ca53220555b7d6.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (15/16) (49a7f292732ad550d7f078f8a01a6658) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (15/16) (49a7f292732ad550d7f078f8a01a6658).
[ToKeyedWorkItem (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (15/16) (49a7f292732ad550d7f078f8a01a6658) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (15/16) (9016656177e43ab185ca53220555b7d6) 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 49a7f292732ad550d7f078f8a01a6658.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (15/16) (49a7f292732ad550d7f078f8a01a6658) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (612dfff9e8f8fde87b697c201e6d1847) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (612dfff9e8f8fde87b697c201e6d1847).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (612dfff9e8f8fde87b697c201e6d1847) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 612dfff9e8f8fde87b697c201e6d1847.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (7/16) (3f639afbedb8cd4e0593717bb4682d34) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (7/16) (3f639afbedb8cd4e0593717bb4682d34).
[ToKeyedWorkItem (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (7/16) (3f639afbedb8cd4e0593717bb4682d34) [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 3f639afbedb8cd4e0593717bb4682d34.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (8afb5ca216291b76406985d921352098) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (8afb5ca216291b76406985d921352098).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (8afb5ca216291b76406985d921352098) [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$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 8afb5ca216291b76406985d921352098.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16) (626e7ddc424d7c8aecd58ddc337a9f56) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16) (626e7ddc424d7c8aecd58ddc337a9f56).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16) (626e7ddc424d7c8aecd58ddc337a9f56) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (7/16) (612dfff9e8f8fde87b697c201e6d1847) 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$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 626e7ddc424d7c8aecd58ddc337a9f56.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (4/16) (bd8a25c7de3f39d152a6dc5663762e90) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (4/16) (bd8a25c7de3f39d152a6dc5663762e90).
[ToKeyedWorkItem (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (4/16) (bd8a25c7de3f39d152a6dc5663762e90) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (7/16) (3f639afbedb8cd4e0593717bb4682d34) 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 bd8a25c7de3f39d152a6dc5663762e90.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (4/16) (8afb5ca216291b76406985d921352098) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (8/16) (4e4b5302a7ab7d495f75cdbe83d77821) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (8/16) (4e4b5302a7ab7d495f75cdbe83d77821).
[ToKeyedWorkItem (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (8/16) (4e4b5302a7ab7d495f75cdbe83d77821) [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 4e4b5302a7ab7d495f75cdbe83d77821.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (8/16) (626e7ddc424d7c8aecd58ddc337a9f56) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (4/16) (bd8a25c7de3f39d152a6dc5663762e90) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (8/16) (4e4b5302a7ab7d495f75cdbe83d77821) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (f38c40f5094961bdf246229c7f2f7e15) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (f38c40f5094961bdf246229c7f2f7e15).
[PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (f38c40f5094961bdf246229c7f2f7e15) [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$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 f38c40f5094961bdf246229c7f2f7e15.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - ToKeyedWorkItem (2/16) (38ae2f302fa3de69705c7799da466bc7) switched from RUNNING to FINISHED.
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for ToKeyedWorkItem (2/16) (38ae2f302fa3de69705c7799da466bc7).
[ToKeyedWorkItem (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task ToKeyedWorkItem (2/16) (38ae2f302fa3de69705c7799da466bc7) [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 38ae2f302fa3de69705c7799da466bc7.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey -> PAssert$155/GroupGlobally/GatherAllOutputs/GroupByKey.out/beam:env:docker:v1:0 (2/16) (f38c40f5094961bdf246229c7f2f7e15) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - ToKeyedWorkItem (2/16) (38ae2f302fa3de69705c7799da466bc7) switched from RUNNING to FINISHED.
[grpc-default-executor-155] WARN org.apache.beam.sdk.metrics.MetricsEnvironment - Reporting metrics are not supported in the current execution environment.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (0eca992f5002726b3ea880dcdcb6f453) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (0eca992f5002726b3ea880dcdcb6f453).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (0eca992f5002726b3ea880dcdcb6f453) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 0eca992f5002726b3ea880dcdcb6f453.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (1/16) (0eca992f5002726b3ea880dcdcb6f453) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (708766bcf9afdf763cdc4f1708ccf41c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (708766bcf9afdf763cdc4f1708ccf41c).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (708766bcf9afdf763cdc4f1708ccf41c) [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$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 708766bcf9afdf763cdc4f1708ccf41c.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (4f11225fc61d00d7ba759f64b771f967) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (4f11225fc61d00d7ba759f64b771f967).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (4f11225fc61d00d7ba759f64b771f967) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (12/16) (708766bcf9afdf763cdc4f1708ccf41c) 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$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 4f11225fc61d00d7ba759f64b771f967.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (3/16) (4f11225fc61d00d7ba759f64b771f967) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (16d55c1ce805dac570793c415e552e1f) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (16d55c1ce805dac570793c415e552e1f).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (16d55c1ce805dac570793c415e552e1f) [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$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 16d55c1ce805dac570793c415e552e1f.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (3aa1ee03661e8666954bdbfaf7be7e23) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (df80c5aa3ace867cd0bdb063ebfafd95) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (08a353a652c445124bb15121334df81b) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (08a353a652c445124bb15121334df81b).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (df80c5aa3ace867cd0bdb063ebfafd95).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (3aa1ee03661e8666954bdbfaf7be7e23).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (08a353a652c445124bb15121334df81b) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (df80c5aa3ace867cd0bdb063ebfafd95) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (3aa1ee03661e8666954bdbfaf7be7e23) [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$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 08a353a652c445124bb15121334df81b.
[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$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 df80c5aa3ace867cd0bdb063ebfafd95.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (a4f616381320358b7614d94e7313a1e8) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (a4f616381320358b7614d94e7313a1e8).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (2/16) (16d55c1ce805dac570793c415e552e1f) 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$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 3aa1ee03661e8666954bdbfaf7be7e23.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (a4f616381320358b7614d94e7313a1e8) [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$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 a4f616381320358b7614d94e7313a1e8.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (5/16) (08a353a652c445124bb15121334df81b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (8/16) (df80c5aa3ace867cd0bdb063ebfafd95) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (535f60d3597069fe36c456bb6ac903f5) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (535f60d3597069fe36c456bb6ac903f5).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (535f60d3597069fe36c456bb6ac903f5) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (11/16) (3aa1ee03661e8666954bdbfaf7be7e23) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 535f60d3597069fe36c456bb6ac903f5.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (0929d46ce4505d0066071e396b01ac2b) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (0929d46ce4505d0066071e396b01ac2b).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (8857a93a0b6103c0e88bbf43c2e3f66c) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (0929d46ce4505d0066071e396b01ac2b) [FINISHED]
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (8857a93a0b6103c0e88bbf43c2e3f66c).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (15/16) (a4f616381320358b7614d94e7313a1e8) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (8857a93a0b6103c0e88bbf43c2e3f66c) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 0929d46ce4505d0066071e396b01ac2b.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 8857a93a0b6103c0e88bbf43c2e3f66c.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (13/16) (535f60d3597069fe36c456bb6ac903f5) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (097bcc1001a63955be4538cec8a60854) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (097bcc1001a63955be4538cec8a60854).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (097bcc1001a63955be4538cec8a60854) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 097bcc1001a63955be4538cec8a60854.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (9/16) (0929d46ce4505d0066071e396b01ac2b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (16/16) (8857a93a0b6103c0e88bbf43c2e3f66c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (6/16) (097bcc1001a63955be4538cec8a60854) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (8d285fe5bab12667b4c3cf949591634b) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (8d285fe5bab12667b4c3cf949591634b).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (8d285fe5bab12667b4c3cf949591634b) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 8d285fe5bab12667b4c3cf949591634b.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (34c7880a7230f4cd40a1621490527628) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (34c7880a7230f4cd40a1621490527628).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (34c7880a7230f4cd40a1621490527628) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 34c7880a7230f4cd40a1621490527628.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (14/16) (8d285fe5bab12667b4c3cf949591634b) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (50e9be4a3d7b3c18103bde4a6801bc37) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (50e9be4a3d7b3c18103bde4a6801bc37).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (50e9be4a3d7b3c18103bde4a6801bc37) [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$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 50e9be4a3d7b3c18103bde4a6801bc37.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (7/16) (34c7880a7230f4cd40a1621490527628) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (10/16) (50e9be4a3d7b3c18103bde4a6801bc37) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (f8def2434957035a03afa8a798a5aa35) switched from RUNNING to FINISHED.
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (f8def2434957035a03afa8a798a5aa35).
[PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (f8def2434957035a03afa8a798a5aa35) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 f8def2434957035a03afa8a798a5aa35.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - PAssert$155/GroupGlobally/GroupDummyAndContents -> PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0 (4/16) (f8def2434957035a03afa8a798a5aa35) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1202064437-505b995f (3f3e2af341a1bdc340ed1afef82e8fac) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 3f3e2af341a1bdc340ed1afef82e8fac.
[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 3f3e2af341a1bdc340ed1afef82e8fac 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-1202064437-505b995f(3f3e2af341a1bdc340ed1afef82e8fac).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 3f3e2af341a1bdc340ed1afef82e8fac.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection cd2eb40d63878d1c666477aec0082dcd: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager 97da3cefc21d8857f85bdd28cd644858@akka://flink/user/jobmanager_261 for job 3f3e2af341a1bdc340ed1afef82e8fac from the resource manager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher3c18c3aa-2a68-4b5c-8f45-7a4ebd195c06.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher3c18c3aa-2a68-4b5c-8f45-7a4ebd195c06.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 3f3e2af341a1bdc340ed1afef82e8fac with leader id 97da3cefc21d8857f85bdd28cd644858 lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-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{f8455b57f708495e9dd6f2f1356f8050}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{341774da8ac84cba3a0c76122d60cf99}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{b7918e7e374541f85184fbf0aefa9fe2}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{2c8bbcce0d49e64931feb2508e8d592d}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{a356310d521f1de129efb3ee215ebb7e}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{332c0be50960c75d2646678546acd548}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{ac3ea71fcbabda5e7f7f7d9d8757c77e}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{618c9f7396eca7c22d1b2fda0c6b94bf}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:14, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{bccc7918e9301efb6a5d6b8fb6a64b17}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{8b24ebaae20bb9b73990d2eb3392d03f}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{d9af5daf1d4b769327df3def020b8402}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{eabdf0a037e8c879d9fdfb4cc93a065f}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{7240b23836a0286809f82fdfb703c580}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{9c3ef02db53eaf9c5328e546831badee}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Free slot TaskSlot(index:3, state:ALLOCATED, resource profile: ResourceProfile{cpuCores=1.0, heapMemoryInMB=42, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0}, allocationId: AllocationID{4225e7be1218c613c17ae3c6f1b0a8d5}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[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{119cbdfd0bb06e431f6f2fb02ebaf4ba}, jobId: 3f3e2af341a1bdc340ed1afef82e8fac).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Remove job 3f3e2af341a1bdc340ed1afef82e8fac from job leader monitoring.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 3f3e2af341a1bdc340ed1afef82e8fac.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
[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-b091ecc4-0209-4d45-8295-65e7ba6758e1
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-8] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher3c18c3aa-2a68-4b5c-8f45-7a4ebd195c06.
[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_260.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:40969
[flink-akka.actor.default-dispatcher-7] 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 9269 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@3b8b8f37
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1202064437-505b995f_9e00c3f1-e417-40e9-9ec6-246f6332b153/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-1202064437-505b995f_9e00c3f1-e417-40e9-9ec6-246f6332b153/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:38137
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:43599
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.567 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.071 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerStreaming>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerStreaming (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 40 mins 45.295 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 44m 53s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/a7ryfsj6ioonc
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