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/11/21 22:14:41 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #390
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/390/display/redirect?page=changes>
Changes:
[github] typo fix in experiments flag name in the log (#7076)
------------------------------------------
[...truncated 499.26 MB...]
[jobmanager-future-thread-11] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b) [DEPLOYING]
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16) (72582dde08039cc8959fff8e63de9bc8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b) [DEPLOYING].
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16) (72582dde08039cc8959fff8e63de9bc8).
[MapPartition (MapPartition at 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 MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16) (72582dde08039cc8959fff8e63de9bc8) [FINISHED]
[jobmanager-future-thread-14] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 7ac60b57820af4f99afe4283300c88d7.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (14/16) (7ac60b57820af4f99afe4283300c88d7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 1eb3f1236c6c853bdc5deae3bed3ab7e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) c3e9fcd88a935ee1a030445c94a9cf3d.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 34d3c6f46f2f75a0f6ec0cf727ef00a4.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (1eb3f1236c6c853bdc5deae3bed3ab7e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16) (c3e9fcd88a935ee1a030445c94a9cf3d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (34d3c6f46f2f75a0f6ec0cf727ef00a4) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 781c1e5c8d60edee98a45710cfcedf7a.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (8/16) (781c1e5c8d60edee98a45710cfcedf7a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) ad619cc14d1ebe4e9f4e193cf878ab11.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 4f43aff9f99f43c09e85a0ed1be1ada2.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 19ec9e7f3c8ed0f9d2779ac1f17e2b8a.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (12/16) (ad619cc14d1ebe4e9f4e193cf878ab11) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (16/16) (4f43aff9f99f43c09e85a0ed1be1ada2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (10/16) (19ec9e7f3c8ed0f9d2779ac1f17e2b8a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) ac39ff9d74e47b2d4d42db0ad14faf08.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (ac39ff9d74e47b2d4d42db0ad14faf08) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 771bfd095cf2ddaa0afd9ce206ba002a.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 274bd3a6e3a8772b3c685e9710141be2.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) b97a4f91324f3e785738ebb1e7f6e97e.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (11/16) (771bfd095cf2ddaa0afd9ce206ba002a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (274bd3a6e3a8772b3c685e9710141be2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (b97a4f91324f3e785738ebb1e7f6e97e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) de6c2f3a50157eef0f78820415770390.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (13/16) (de6c2f3a50157eef0f78820415770390) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c) switched from DEPLOYING to RUNNING.
[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 MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 72582dde08039cc8959fff8e63de9bc8.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16) (72582dde08039cc8959fff8e63de9bc8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) [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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 0f7dd42f5e680120248d085720078c0b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (1/16) (0f7dd42f5e680120248d085720078c0b) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 486384f5bff923557b8bff025175f71f.
[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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 00b643c55c6c1c06f2b35a156fb58152.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (14/16) (486384f5bff923557b8bff025175f71f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) [DEPLOYING].
[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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 885e68cc6ee529d0fd3b9a40374ae858.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (7/16) (00b643c55c6c1c06f2b35a156fb58152) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 89965dcd8593dc10de9406142fd80e9c.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (15/16) (885e68cc6ee529d0fd3b9a40374ae858) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 39a9ac831ce238bdc4d3a6844ad6ae28.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (9/16) (89965dcd8593dc10de9406142fd80e9c) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 3a19cac77aa4a647b72bbf87131f9235.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) switched from DEPLOYING to RUNNING.
[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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 6774753afcb601e85ccd781f394fb299.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (6/16) (39a9ac831ce238bdc4d3a6844ad6ae28) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 4c9be74b50a274c4ab7a62283a4cd22c.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (16/16) (3a19cac77aa4a647b72bbf87131f9235) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 7d2b1feb418be0c82d8fff6a5c5cf34c.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (10/16) (6774753afcb601e85ccd781f394fb299) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) ccf1366233616c587b1bcfcffb6f77fc.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (5/16) (4c9be74b50a274c4ab7a62283a4cd22c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (4/16) (7d2b1feb418be0c82d8fff6a5c5cf34c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (3/16) (ccf1366233616c587b1bcfcffb6f77fc) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) 080fdc3b76a30e16be61a6b8c5335944.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@36a0e903) (2/16) (080fdc3b76a30e16be61a6b8c5335944) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1121221406-205fb0d9 (808a5e53d4bd3e80da500cf1478e19f2) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 808a5e53d4bd3e80da500cf1478e19f2 reached globally terminal state FINISHED.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher5d2ed885-b57e-4952-a9bf-224b27940900.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1121221406-205fb0d9(808a5e53d4bd3e80da500cf1478e19f2).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher5d2ed885-b57e-4952-a9bf-224b27940900.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 40d252b8c096a533a96db88342356ee2: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-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-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 808a5e53d4bd3e80da500cf1478e19f2 with leader id ba79ca11266818a362bdadd24bf34900 lost leadership.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-4717e21d-3bb4-403f-87f5-1fccd6275547
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher5d2ed885-b57e-4952-a9bf-224b27940900.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
[ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:45847
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 11870 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1121221406-205fb0d9_816a7d71-9d10-4422-8f89-6e683aff3b86/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-1121221406-205fb0d9_816a7d71-9d10-4422-8f89-6e683aff3b86/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:38877
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:33129
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.io.CountingSourceTest > testBoundedSourceSplits SKIPPED
197 tests completed, 1 failed, 3 skipped
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 10,5,main]) completed. Took 47 mins 33.12 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 50m 43s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/xjemcgqh3inoa
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