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/22 18:51:37 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #399
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/399/display/redirect>
------------------------------------------
[...truncated 509.25 MB...]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (2/16) (0b2b8aaa8426a5ca5ca9739909d1add8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (12/16) (c01c89646bc8b56ee6383217a1877ada) 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@42d4fab1) (14/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (10/16) (e6f1013025872f7136be1a3cc507a61c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (14/16) (e3b9cf17e67964eaf57981025039c4fd) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56) 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@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (ae30b9d18deb963cd6b81b40f3e00ce6) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (ae30b9d18deb963cd6b81b40f3e00ce6).
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (ae30b9d18deb963cd6b81b40f3e00ce6) [FINISHED]
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (2a356f258ab951ad916f514b6a0257c0) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (2a356f258ab951ad916f514b6a0257c0).
[jobmanager-future-thread-14] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56).
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (2a356f258ab951ad916f514b6a0257c0) [FINISHED]
[jobmanager-future-thread-14] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) 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@42d4fab1) (5/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (attempt #0) to localhost
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16) (b40d975eee210288766af3bc669eaa62) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16) (b40d975eee210288766af3bc669eaa62).
[jobmanager-future-thread-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16) (b40d975eee210288766af3bc669eaa62) [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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 211801c3b0832a696537399c342db913.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) 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@42d4fab1) (11/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (16/16) (211801c3b0832a696537399c342db913) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c) [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@42d4fab1) b73c66ce3b980cf740cec0fad86dfe55.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9) [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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 4b2953c78d6f01475ba544cda33560f5.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 3051f606ea1a5ac0abe8ea1c014d09d5.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (2/16) (b73c66ce3b980cf740cec0fad86dfe55) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (1b5da0940a298fdf9f41f40f18c2127b) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (1b5da0940a298fdf9f41f40f18c2127b).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16).
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (1b5da0940a298fdf9f41f40f18c2127b) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (13/16) (4b2953c78d6f01475ba544cda33560f5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (3051f606ea1a5ac0abe8ea1c014d09d5) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16).
[jobmanager-future-thread-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) 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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) cd8d1ca44806e61f36e9f8721b36dcdd.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16) (cd8d1ca44806e61f36e9f8721b36dcdd) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b) 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@42d4fab1) (6/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c) [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@42d4fab1) 69a28d2a12a3d1c58e8955a67ea4738b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb) 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@42d4fab1) fa6e7faedeccebb6b0225db494315518.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb) [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@42d4fab1) a3fd96177e00a4ecafe5f197cc041547.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (8/16) (69a28d2a12a3d1c58e8955a67ea4738b) 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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) ae30b9d18deb963cd6b81b40f3e00ce6.
[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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 2a356f258ab951ad916f514b6a0257c0.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (1/16) (fa6e7faedeccebb6b0225db494315518) 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@42d4fab1) 2218649599a36ce05c7f8462a072ab56.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (12/16) (a3fd96177e00a4ecafe5f197cc041547) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (ae30b9d18deb963cd6b81b40f3e00ce6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (2a356f258ab951ad916f514b6a0257c0) 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@42d4fab1) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (14/16) (2218649599a36ce05c7f8462a072ab56) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb) 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@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) 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@42d4fab1) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) [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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) b40d975eee210288766af3bc669eaa62.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16) (b40d975eee210288766af3bc669eaa62) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) [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 MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 1b5da0940a298fdf9f41f40f18c2127b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (1b5da0940a298fdf9f41f40f18c2127b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) 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@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) 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@42d4fab1) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) 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@42d4fab1) fc7ea8ee9877ce3a0452f281deb3430b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) [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@42d4fab1) 1eec0c5ff3e110abcc99883dc3aeb7a9.
[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@42d4fab1) 7c87a0adb58b6771202aa6d06562e36c.
[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@42d4fab1) 2dbf3a28069a497d6cf94fea7ed22515.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (7/16) (fc7ea8ee9877ce3a0452f281deb3430b) 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@42d4fab1) 7400e0ded3bb9d70ca03e9d850b13cbb.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (16/16) (1eec0c5ff3e110abcc99883dc3aeb7a9) 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@42d4fab1) 3344c42c006e7016f1706b011fbcbbe1.
[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@42d4fab1) 715fbdaf5fdd0827e96152a3f8cce1ee.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (10/16) (7c87a0adb58b6771202aa6d06562e36c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) 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@42d4fab1) bfb92ebc7d9af026d20a5442c5f1c52b.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (13/16) (2dbf3a28069a497d6cf94fea7ed22515) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (6/16) (7400e0ded3bb9d70ca03e9d850b13cbb) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (5/16) (3344c42c006e7016f1706b011fbcbbe1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (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@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) f8e1e01db0a5c9e1a1e092c54fd5dd91.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (11/16) (715fbdaf5fdd0827e96152a3f8cce1ee) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (9/16) (bfb92ebc7d9af026d20a5442c5f1c52b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@42d4fab1) (3/16) (f8e1e01db0a5c9e1a1e092c54fd5dd91) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1122185056-9974723b (2a52204f61f47cd9145332dc2071d3dd) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 2a52204f61f47cd9145332dc2071d3dd 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-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher8160b42a-4a8d-4102-a199-e0d094d432be.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1122185056-9974723b(2a52204f61f47cd9145332dc2071d3dd).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher8160b42a-4a8d-4102-a199-e0d094d432be.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 365c4c4fd0328724f6a3ec0646cb3948: 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.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 2a52204f61f47cd9145332dc2071d3dd with leader id 8b8c9baedc7111baac4003bd2cc84c6a lost leadership.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher8160b42a-4a8d-4102-a199-e0d094d432be.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-031e403a-13fe-4e77-a17c-3436c354573d
[flink-akka.actor.default-dispatcher-5] 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.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
[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-6] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41565
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 13040 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1122185056-9974723b_3e2b6990-9644-438b-a967-20eb8b181d13/MANIFEST has 186 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1122185056-9974723b_3e2b6990-9644-438b-a967-20eb8b181d13/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:41453
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:42045
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
197 tests completed, 1 failed, 2 skipped
Finished generating test XML results (4.98 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.949 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 48 mins 21.262 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 51m 27s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/lqzvdxy4cfnwu
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