You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/10/24 21:25:31 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #97
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/97/display/redirect?page=changes>
Changes:
[amyrvold] [BEAM-4431] Add "Edit this Page" button to website
[scott] [BEAM-5837] Add health check prober for community metrics infrastructure
------------------------------------------
[...truncated 346.59 MB...]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (13/16) (c069413564227d64f43f72e84c9bc6f7) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16) (c069413564227d64f43f72e84c9bc6f7) [DEPLOYING].
[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) (9aa9d32a7072c00dacf19c4918408755) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (4/16) (04269e7678aadb5d9b60aaa884a91a12) [FINISHED]
[jobmanager-future-thread-11] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) 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@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) 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@7acd9684) (1/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16) (c069413564227d64f43f72e84c9bc6f7) [DEPLOYING].
[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) (3d7826c03afbd65514c40e85d017de02) 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) (3d7826c03afbd65514c40e85d017de02).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16) (c069413564227d64f43f72e84c9bc6f7) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-1] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16).
[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) (3d7826c03afbd65514c40e85d017de02) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16) (c069413564227d64f43f72e84c9bc6f7) 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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 34746813d997a3d405babc8a5e9412f9.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16) (c069413564227d64f43f72e84c9bc6f7) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16) (c069413564227d64f43f72e84c9bc6f7).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (13/16) (c069413564227d64f43f72e84c9bc6f7) [FINISHED]
[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) (14/16) (34746813d997a3d405babc8a5e9412f9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16).
[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) d8fe322ac3830c36480f9ca55e658214.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794) [DEPLOYING].
[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) (11/16) (d8fe322ac3830c36480f9ca55e658214) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794) 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@7acd9684) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe) 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@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794) [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) bebcb53d646cd9aadd8980b6745896b0.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1) 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 MapPartition (MapPartition at PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 3a820ea6625015e366bf1d5ad4e6c733.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1) [DEPLOYING]
[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) (3/16) (bebcb53d646cd9aadd8980b6745896b0) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1) switched from DEPLOYING to RUNNING.
[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) (12/16) (3a820ea6625015e366bf1d5ad4e6c733) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16) (1131315114636a0af4b746428d14355e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (12/16) (1131315114636a0af4b746428d14355e) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16) (1131315114636a0af4b746428d14355e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1) 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@7acd9684) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16) (1131315114636a0af4b746428d14355e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16) (1131315114636a0af4b746428d14355e) 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@7acd9684) (12/16) (1131315114636a0af4b746428d14355e) 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) 1cc52622def548048aad80a0797c726b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515) [DEPLOYING].
[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) (10/16) (1cc52622def548048aad80a0797c726b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16) (1131315114636a0af4b746428d14355e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16) (1131315114636a0af4b746428d14355e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (12/16) (1131315114636a0af4b746428d14355e) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515) 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@7acd9684) (10/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515) [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@7acd9684) 73a34d6c1061bbd12971306a126ed8cf.
[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) 6dde31327573a7fd5b3635a1db3fd980.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (8/16) (73a34d6c1061bbd12971306a126ed8cf) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16).
[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) (7/16) (6dde31327573a7fd5b3635a1db3fd980) 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@7acd9684) f70fdbb37973fe4e5bed53eabd065d39.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 19fa4056116c95ce1e24b233e0ed7c9f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (15/16) (f70fdbb37973fe4e5bed53eabd065d39) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab) 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@7acd9684) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c) switched from DEPLOYING to RUNNING.
[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) (9/16) (19fa4056116c95ce1e24b233e0ed7c9f) 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@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c) [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) 37de149c5b3f208716763fa2146f7ebf.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175) 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@7acd9684) 47ff059fd3be1df193191b080902684b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175) [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) (6/16) (37de149c5b3f208716763fa2146f7ebf) 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@7acd9684) (6/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (2/16) (47ff059fd3be1df193191b080902684b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 9aa9d32a7072c00dacf19c4918408755.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175) 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@7acd9684) 04269e7678aadb5d9b60aaa884a91a12.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c) [DEPLOYING].
[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) (1/16) (9aa9d32a7072c00dacf19c4918408755) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c) 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@7acd9684) (1/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c).
[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) 3d7826c03afbd65514c40e85d017de02.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (4/16) (04269e7678aadb5d9b60aaa884a91a12) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c) switched from DEPLOYING to RUNNING.
[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) (3d7826c03afbd65514c40e85d017de02) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) [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@7acd9684) c069413564227d64f43f72e84c9bc6f7.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) [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@7acd9684) ed0401798aa0d448dc1c9d009b635cfe.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) 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@7acd9684) 0d80b4c6aa05f2950a18f23e7a41d794.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (13/16) (c069413564227d64f43f72e84c9bc6f7) 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@7acd9684) 1131315114636a0af4b746428d14355e.
[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@7acd9684) 234ecee9c4ca505086d373aec8dac4a1.
[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@7acd9684) 1ac5cbfd4605c7ca19a4f3491f297515.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) 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@7acd9684) aa52ab641003bf6b142810bc9816c2ab.
[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@7acd9684) fe194532fd3aed63242e8b4bf0f6236c.
[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@7acd9684) 8a03b84b0108945bdfb0212c49bd4175.
[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@7acd9684) 7d6f4b4615534bf3528e960baebdc32c.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (14/16) (ed0401798aa0d448dc1c9d009b635cfe) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (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@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) 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@7acd9684) f208b961a304175b5624fa83d3fff8ac.
[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@7acd9684) 6f07af0adcb5df4a143a499748f5bfb7.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (16/16) (0d80b4c6aa05f2950a18f23e7a41d794) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (12/16) (1131315114636a0af4b746428d14355e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (11/16) (234ecee9c4ca505086d373aec8dac4a1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (3/16) (1ac5cbfd4605c7ca19a4f3491f297515) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (10/16) (aa52ab641003bf6b142810bc9816c2ab) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (7/16) (fe194532fd3aed63242e8b4bf0f6236c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (9/16) (8a03b84b0108945bdfb0212c49bd4175) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (6/16) (7d6f4b4615534bf3528e960baebdc32c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (5/16) (f208b961a304175b5624fa83d3fff8ac) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@7acd9684) (1/16) (6f07af0adcb5df4a143a499748f5bfb7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1024212501-24bfa4a5 (142bcb4aac80b2812751174c0540bc71) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 142bcb4aac80b2812751174c0540bc71 reached globally terminal state FINISHED.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1024212501-24bfa4a5(142bcb4aac80b2812751174c0540bc71).
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher93f5801b-8505-4755-bc12-32097ab51470.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_242.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher93f5801b-8505-4755-bc12-32097ab51470.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 97133b2e4eab46b83a4203d81603c0f6 from the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 6dc128b2a2c32185a71f1f35fea2181e: 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-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 142bcb4aac80b2812751174c0540bc71 with leader id a2210b1e47fa15a0db23c815fe144fc7 lost leadership.
[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-6d3dc1e5-50b1-4fe6-92ca-73ba6aab655e
[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-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/dispatcher93f5801b-8505-4755-bc12-32097ab51470.
[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_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-5] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41359
[flink-akka.actor.default-dispatcher-5] 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 11525 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1024212501-24bfa4a5_fe480810-a65e-466d-a29f-49ee1bc6ab5c/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-1024212501-24bfa4a5_fe480810-a65e-466d-a29f-49ee1bc6ab5c/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:46175
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:38089
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.transforms.CombineTest$WindowingTests > testCombineGloballyLambda SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 2,5,main]) completed. Took 43 mins 26.886 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 137
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 46m 8s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/efcfcjvrojiks
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink
#98
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/98/display/redirect?page=changes>