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/06 22:02:21 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #235
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/235/display/redirect?page=changes>
Changes:
[mxm] [BEAM-5971] Prevent unwanted shutdown of UnboundedSourceWrapper
[mxm] [BEAM-5971] Use Thread.sleep instead of Object#wait
[markliu] Updating Python worker container to beam-master-20181106
------------------------------------------
[...truncated 501.69 MB...]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (13/16) (0340ea128d90b0fbc2ca9340d5d3bf3d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (15/16) (f27920699bf383e8b31e7c0895227597) 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@599faf03) (13/16) (959cb9669a955d93ff6c093d541d4d8d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16).
[jobmanager-future-thread-11] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-10] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) 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@599faf03) (4/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8) [DEPLOYING].
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 007858a79924c7d2b4279dda25979b78.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611) [DEPLOYING]
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) f8310b6263987c8661c8713f9f17b840.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611) [DEPLOYING].
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) aed61df3f1a2e913fee45c248a9599d6.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (12/16) (007858a79924c7d2b4279dda25979b78) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (11/16) (f8310b6263987c8661c8713f9f17b840) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (10/16) (aed61df3f1a2e913fee45c248a9599d6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8) 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@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f) 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@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03) [DEPLOYING].
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 51dd1b320e76d1c939d1ab045d32e8f3.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e) [DEPLOYING].
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) a11899c31985e59958485063e95539e3.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (51dd1b320e76d1c939d1ab045d32e8f3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (7/16) (a11899c31985e59958485063e95539e3) 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@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03) 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@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd) 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@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd).
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 0fbaf7f3ebbe22776c69fc2c092034e9.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (6/16) (0fbaf7f3ebbe22776c69fc2c092034e9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def) 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@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def) [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@599faf03) 2b4e4bd7a8c982b317a0a1f02f4f9e92.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae) [DEPLOYING]
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 5da2bf5f2155f6694df68a96f2f4e2e4.
[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@599faf03) dae8bd3a44516e0591ea0877efee065f.
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) deed69925e8d420880b33d7884db0adb.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (16/16) (2b4e4bd7a8c982b317a0a1f02f4f9e92) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (3/16) (5da2bf5f2155f6694df68a96f2f4e2e4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (2/16) (dae8bd3a44516e0591ea0877efee065f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (5/16) (deed69925e8d420880b33d7884db0adb) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae) 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@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16) (02ca4423aef709afa7699551187bae14) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (3/16) (02ca4423aef709afa7699551187bae14) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16) (02ca4423aef709afa7699551187bae14) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16) (02ca4423aef709afa7699551187bae14) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16) (02ca4423aef709afa7699551187bae14) 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@599faf03) (3/16) (02ca4423aef709afa7699551187bae14) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16).
[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@599faf03) f27920699bf383e8b31e7c0895227597.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d) [DEPLOYING].
[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@599faf03) 959cb9669a955d93ff6c093d541d4d8d.
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 09281228d0d2c74fcb8ffc584403204b.
[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 MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) b31b8da5b2035ac1ceb2b21683237d34.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (15/16) (f27920699bf383e8b31e7c0895227597) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (13/16) (959cb9669a955d93ff6c093d541d4d8d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16) (02ca4423aef709afa7699551187bae14) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16) (02ca4423aef709afa7699551187bae14).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (3/16) (02ca4423aef709afa7699551187bae14) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (1/16) (09281228d0d2c74fcb8ffc584403204b) 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@599faf03) (4/16).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (4/16) (b31b8da5b2035ac1ceb2b21683237d34) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) 1c2571f67f043fc5eca82cf501d75611.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) [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@599faf03) eed6b4404bdac25c903eb5be63f87cf8.
[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@599faf03) 8c4791dbd70e3983d28b6288060b901f.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (14/16) (1c2571f67f043fc5eca82cf501d75611) 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@599faf03) ca28e5c58588a1d18e17ecc4bcb22ecd.
[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@599faf03) d6fef602ea2bacd80a524a5328244a6e.
[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@599faf03) 190c9fb1ffdeeb4ff19ae0f151e3ab03.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (8/16) (eed6b4404bdac25c903eb5be63f87cf8) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) [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@599faf03) 0bec7a9bc31ca92ea240611347065def.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) [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@599faf03) c1232c741c6a87334d3749405ebd99ae.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) 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@599faf03) 02ca4423aef709afa7699551187bae14.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (12/16) (8c4791dbd70e3983d28b6288060b901f) 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@599faf03) d76ab0553a123db1689d0e4024bcc94d.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (9/16) (ca28e5c58588a1d18e17ecc4bcb22ecd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (11/16) (d6fef602ea2bacd80a524a5328244a6e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (10/16) (190c9fb1ffdeeb4ff19ae0f151e3ab03) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (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@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) [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@599faf03) 9a5cfc218ad85894b06124d2d10d22a6.
[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@599faf03) 6ac558df9ea51731f28a5a0a9b5d67c9.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (7/16) (0bec7a9bc31ca92ea240611347065def) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (6/16) (c1232c741c6a87334d3749405ebd99ae) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (3/16) (02ca4423aef709afa7699551187bae14) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (5/16) (d76ab0553a123db1689d0e4024bcc94d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (1/16) (9a5cfc218ad85894b06124d2d10d22a6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@599faf03) (4/16) (6ac558df9ea51731f28a5a0a9b5d67c9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1106220144-1cd3c325 (60121da5d7202153888e3b7313d4a9d9) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 60121da5d7202153888e3b7313d4a9d9 reached globally terminal state FINISHED.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1106220144-1cd3c325(60121da5d7202153888e3b7313d4a9d9).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcherf3a9986e-794c-4256-b5c8-ca38b8f0649a.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherf3a9986e-794c-4256-b5c8-ca38b8f0649a.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 1cd93b0e4b483d8c592d86225899a1c7: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-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-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 60121da5d7202153888e3b7313d4a9d9 with leader id 9c211247737a1fbf7ca158bacb8f4a4c 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/dispatcherf3a9986e-794c-4256-b5c8-ca38b8f0649a.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-5f3848b5-67cb-4fc5-a125-de94389501c2
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_212.
[ForkJoinPool.commonPool-worker-4] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:36921
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 11336 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1106220144-1cd3c325_577a4c9d-8704-44c2-b182-477691336f35/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-1106220144-1cd3c325_577a4c9d-8704-44c2-b182-477691336f35/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:35921
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:41023
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
187 tests completed, 1 failed, 1 skipped
Finished generating test XML results (2.999 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 (2.089 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 7,5,main]) completed. Took 37 mins 33.204 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 41m 4s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/g2i3e57cqsh5u
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Jenkins build is back to normal : beam_PostCommit_Java_PVR_Flink
#236
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/236/display/redirect?page=changes>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org