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/04 12:45:59 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #213
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/213/display/redirect>
------------------------------------------
[...truncated 501.41 MB...]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16) (bce2e4050a7578df5ed8e6e01f09cbbd) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16) (bce2e4050a7578df5ed8e6e01f09cbbd) 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@63d1264d) (11/16) (bce2e4050a7578df5ed8e6e01f09cbbd) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (a5d6a93b3cf7bb4e62a3e4146e9b44a2) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (a5d6a93b3cf7bb4e62a3e4146e9b44a2).
[MapPartition (MapPartition at PAssert$148/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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (a5d6a93b3cf7bb4e62a3e4146e9b44a2) [FINISHED]
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (0e8e20dbcbfbb6f41d27d4a0fd2d7399) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16) (bce2e4050a7578df5ed8e6e01f09cbbd) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (0e8e20dbcbfbb6f41d27d4a0fd2d7399).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16) (bce2e4050a7578df5ed8e6e01f09cbbd).
[jobmanager-future-thread-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (064550574188634dc132adb55c0eeb20) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$148/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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (0e8e20dbcbfbb6f41d27d4a0fd2d7399) [FINISHED]
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (064550574188634dc132adb55c0eeb20).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16) (bce2e4050a7578df5ed8e6e01f09cbbd) [FINISHED]
[jobmanager-future-thread-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at PAssert$148/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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (064550574188634dc132adb55c0eeb20) [FINISHED]
[jobmanager-future-thread-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) switched from SCHEDULED to DEPLOYING.
[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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 1985d9e77841d2386d6b640f13d7167d.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (attempt #0) to localhost
[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@63d1264d) dfc113b833c09b38c33d281f9191a2ca.
[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@63d1264d) 0f353b4eb3b5a5f185d02c636c7159e0.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (13/16) (1985d9e77841d2386d6b640f13d7167d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (16/16) (dfc113b833c09b38c33d281f9191a2ca) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44) 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@63d1264d) (8/16) (0f353b4eb3b5a5f185d02c636c7159e0) 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@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44) 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@63d1264d) (13/16).
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (8c48829e7ec56aa040028a8426d1d161) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (8c48829e7ec56aa040028a8426d1d161).
[jobmanager-future-thread-16] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$148/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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (8c48829e7ec56aa040028a8426d1d161) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (attempt #0) to localhost
[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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 77d26646b821e222af3af728b7cde286.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331) switched from CREATED to DEPLOYING.
[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@63d1264d) 09cfc39bd361520e8085ef79cfb348ea.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331) [DEPLOYING]
[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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 403a843482f011ab9001af203d7d33a7.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (10/16) (77d26646b821e222af3af728b7cde286) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (2/16) (09cfc39bd361520e8085ef79cfb348ea) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (403a843482f011ab9001af203d7d33a7) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331) 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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) fff1aacedd7b6e4938974a750479f8cd.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7) [DEPLOYING].
[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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 1380a61bb615b22a1ce29722289903fa.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16) (fff1aacedd7b6e4938974a750479f8cd) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (1380a61bb615b22a1ce29722289903fa) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4) switched from CREATED to DEPLOYING.
[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@63d1264d) c076b58e1e8f2c3faf9893daef82317c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (12/16) (c076b58e1e8f2c3faf9893daef82317c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4) 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@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484) 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@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4) [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@63d1264d) 1841f01bf9f4f5a0651b2869567f58ea.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (15/16) (1841f01bf9f4f5a0651b2869567f58ea) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674) [DEPLOYING]
[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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) a5d6a93b3cf7bb4e62a3e4146e9b44a2.
[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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 0e8e20dbcbfbb6f41d27d4a0fd2d7399.
[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@63d1264d) bce2e4050a7578df5ed8e6e01f09cbbd.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (a5d6a93b3cf7bb4e62a3e4146e9b44a2) 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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 064550574188634dc132adb55c0eeb20.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (0e8e20dbcbfbb6f41d27d4a0fd2d7399) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (11/16) (bce2e4050a7578df5ed8e6e01f09cbbd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (064550574188634dc132adb55c0eeb20) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) 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@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16).
[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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 8c48829e7ec56aa040028a8426d1d161.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (8c48829e7ec56aa040028a8426d1d161) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) 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@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) 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@63d1264d) bd664eb489c089f4c4cd2632e5631d44.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) switched from CREATED to DEPLOYING.
[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@63d1264d) 4a12ebf08d6c8b669e19262cca316331.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) [DEPLOYING].
[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@63d1264d) f823953bab63baf4953dcb890761bdf7.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (14/16) (bd664eb489c089f4c4cd2632e5631d44) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (13/16) (4a12ebf08d6c8b669e19262cca316331) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e).
[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@63d1264d) c8ee988d178a7565d03d52f3dc783da4.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) [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@63d1264d) 00624767e3a3479a80d787c3513ff484.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (10/16) (f823953bab63baf4953dcb890761bdf7) 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@63d1264d) fb77ead1eb249c755d3ff07c31723255.
[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@63d1264d) bfdf546bf2f060f9c2ff1a9d06dca674.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) 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@63d1264d) 3ef30f45ba98a8c744b6cff1ad24578e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b).
[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@63d1264d) 44444cbe4c33a8556cf55eb5741804d6.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (7/16) (c8ee988d178a7565d03d52f3dc783da4) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (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@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) [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@63d1264d) 8bdd24a619a7f2164c1d986965a4b97b.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@63d1264d) (6/16) (00624767e3a3479a80d787c3513ff484) 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@63d1264d) (1/16) (fb77ead1eb249c755d3ff07c31723255) 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@63d1264d) (9/16) (bfdf546bf2f060f9c2ff1a9d06dca674) 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@63d1264d) (3/16) (3ef30f45ba98a8c744b6cff1ad24578e) 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@63d1264d) (4/16) (44444cbe4c33a8556cf55eb5741804d6) 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@63d1264d) (5/16) (8bdd24a619a7f2164c1d986965a4b97b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1104124521-55ee437f (fd0e97432f4912ccb5e556f79bda6265) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job fd0e97432f4912ccb5e556f79bda6265 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-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1104124521-55ee437f(fd0e97432f4912ccb5e556f79bda6265).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_242.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher3ce60c95-8f48-45bd-8520-67a53a03b2ce.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher3ce60c95-8f48-45bd-8520-67a53a03b2ce.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 28affe7e307ba9f87b7c91c5bbf840f5: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 77e5b6a55230f699f81add93f0db9a79 from the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job fd0e97432f4912ccb5e556f79bda6265 with leader id bda9a9fa56ec92e2eb82d5ca98c04070 lost leadership.
[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-674fcf12-5a90-4f3a-b8cb-1ff5c5789687
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher3ce60c95-8f48-45bd-8520-67a53a03b2ce.
[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_242.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:44423
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 11710 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1104124521-55ee437f_1fa694d3-c542-43f4-8d34-5805505c5107/MANIFEST has 185 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1104124521-55ee437f_1fa694d3-c542-43f4-8d34-5805505c5107/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:40283
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:33849
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
187 tests completed, 1 failed, 1 skipped
Finished generating test XML results (3.059 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunner>
Generating HTML test report...
Finished generating test html results (1.523 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 8,5,main]) completed. Took 42 mins 41.841 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner/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 45m 49s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/gdn6gixdhiruy
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
Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink
#215
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/215/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #214
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/214/display/redirect>
------------------------------------------
[...truncated 342.70 MB...]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (15/16) (02ece47636e4f003fc62ee1e0b07d11d) [DEPLOYING].
[jobmanager-future-thread-11] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) switched from CREATED to SCHEDULED.
[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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 0ce0dc5311dcfc8ad4f00a6fc1b71b23.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9) [DEPLOYING].
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (a1772aebd0fd03ef7ec70c45f308d287) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (a1772aebd0fd03ef7ec70c45f308d287).
[MapPartition (MapPartition at PAssert$148/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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (a1772aebd0fd03ef7ec70c45f308d287) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16) (0ce0dc5311dcfc8ad4f00a6fc1b71b23) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9) 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@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) f33053f211480f10a7424819cc6a4b04.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (15/16) (02ece47636e4f003fc62ee1e0b07d11d) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (08b9945d322ec36af328945f3211dba2) 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@6d99557e) (15/16) (02ece47636e4f003fc62ee1e0b07d11d) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (08b9945d322ec36af328945f3211dba2).
[jobmanager-future-thread-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) switched from SCHEDULED to DEPLOYING.
[MapPartition (MapPartition at PAssert$148/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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (08b9945d322ec36af328945f3211dba2) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (f33053f211480f10a7424819cc6a4b04) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (15/16) (02ece47636e4f003fc62ee1e0b07d11d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (15/16) (02ece47636e4f003fc62ee1e0b07d11d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (15/16) (02ece47636e4f003fc62ee1e0b07d11d) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) 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@6d99557e) (7/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6) 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@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) cc656ad8ab1cf42a91283cd2de980248.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) 27e712f429971d1803f4fbd71626bbb9.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) ce9f21b8f4688e9a92295d131e95316e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 3f39e6e1758f48878c69a499f7308658.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16) (cc656ad8ab1cf42a91283cd2de980248) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 2dc6e08f2b337f00b4ca497ae7f76ffd.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8) 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@6d99557e) (16/16) (27e712f429971d1803f4fbd71626bbb9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8) 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@6d99557e) (8/16) (ce9f21b8f4688e9a92295d131e95316e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (10/16) (3f39e6e1758f48878c69a499f7308658) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (12/16) (2dc6e08f2b337f00b4ca497ae7f76ffd) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39) 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@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39) switched from DEPLOYING to RUNNING.
[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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) dcb7f1c2f8e9d962a213e66ba046ca71.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136) [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@6d99557e) b996637bc5891c3c3437a2eda47f9d92.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (13/16) (dcb7f1c2f8e9d962a213e66ba046ca71) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (1/16) (b996637bc5891c3c3437a2eda47f9d92) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16).
[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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 4fcea0bb48cfaf05926480ea96742013.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f) switched from CREATED to 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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 8a70ad16bf92835fa9c3c016e5f591de.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f) [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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) a1772aebd0fd03ef7ec70c45f308d287.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900) [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@6d99557e) d81a82994ccc22d1c27c14df60aeb0c9.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (4fcea0bb48cfaf05926480ea96742013) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (8a70ad16bf92835fa9c3c016e5f591de) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (a1772aebd0fd03ef7ec70c45f308d287) 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@6d99557e) (14/16) (d81a82994ccc22d1c27c14df60aeb0c9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 08b9945d322ec36af328945f3211dba2.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f) 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@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (08b9945d322ec36af328945f3211dba2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) 02ece47636e4f003fc62ee1e0b07d11d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (15/16) (02ece47636e4f003fc62ee1e0b07d11d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) 03a57c6e59320ec3aa072310b3841336.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) 949354717ca2b36e525b0843565264a6.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) 15e7b526ae8d181842d9e3025bdd9fa8.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) 4be2aa2cfbaaa673864d6a17ff0eed39.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) 9fd52c9fab22da5b9c63d0672d272136.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) 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@6d99557e) (5/16) (03a57c6e59320ec3aa072310b3841336) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) fa3cfaee5a652036e9b31cc15a10a900.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) 51a2ccbff9c1aa59558492965717f38f.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) d1fafe24f1f1c6df37fc1e66cb72a09d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (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@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) [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@6d99557e) cdeb1b6b7c724a2a63cd6d660c89e153.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (2/16) (949354717ca2b36e525b0843565264a6) 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@6d99557e) 7239844fc54b7ded7f6a49a733f0bfce.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@6d99557e) (11/16) (15e7b526ae8d181842d9e3025bdd9fa8) 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@6d99557e) (10/16) (4be2aa2cfbaaa673864d6a17ff0eed39) 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@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) 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@6d99557e) (12/16) (9fd52c9fab22da5b9c63d0672d272136) 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@6d99557e) (13/16) (fa3cfaee5a652036e9b31cc15a10a900) 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@6d99557e) (9/16) (51a2ccbff9c1aa59558492965717f38f) 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@6d99557e) (3/16) (d1fafe24f1f1c6df37fc1e66cb72a09d) 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@6d99557e) (7/16) (cdeb1b6b7c724a2a63cd6d660c89e153) 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@6d99557e) (4/16) (7239844fc54b7ded7f6a49a733f0bfce) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1104184731-f3cc3bb0 (2bcd02e2423639d891b5521fcca3e415) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 2bcd02e2423639d891b5521fcca3e415 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/dispatcherba49bb15-2ce7-4186-80b9-7d437e860fe9.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_242.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherba49bb15-2ce7-4186-80b9-7d437e860fe9.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 25f64d9819446b8717769c34af324198 from the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1104184731-f3cc3bb0(2bcd02e2423639d891b5521fcca3e415).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 5fe8dad0b72bc0560fbdcae60d125047: JobManager is shutting down..
[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.rpc.akka.AkkaRpcActor - The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet. Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is started.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 2bcd02e2423639d891b5521fcca3e415 with leader id 955cf04c5174120fa49e1a986b5048bb lost leadership.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-b8a43756-0601-4ee1-85a6-e89557cfc310
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-5] 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.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcherba49bb15-2ce7-4186-80b9-7d437e860fe9.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_242.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-9] 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:34505
[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 11153 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1104184731-f3cc3bb0_87a44884-dc5b-47cf-a66c-e89c7e4754a5/MANIFEST has 185 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1104184731-f3cc3bb0_87a44884-dc5b-47cf-a66c-e89c7e4754a5/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:37185
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:36865
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testCoderInferenceOfList SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 44 mins 17.68 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 1' 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 47m 44s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/zdbkbrzuoks6o
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