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/16 10:09:58 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #337
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/337/display/redirect?page=changes>
Changes:
[github] Merge pull request #6985: [BEAM-5983] Create Combine load test
------------------------------------------
[...truncated 243.01 MB...]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16) (attempt #0) to localhost
[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@243edafa) ec8f17d012662f478e91dfcd5ffa2238.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (1/16) (ec8f17d012662f478e91dfcd5ffa2238) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072) 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@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at PAssert$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16) (101a8a2b13f62cdc54e1694c46f91d69) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16) (101a8a2b13f62cdc54e1694c46f91d69).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16).
[jobmanager-future-thread-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at PAssert$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16) (101a8a2b13f62cdc54e1694c46f91d69) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (attempt #0) to localhost
[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$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) d9225bbe417ba8a2d18d740f537f3581.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (10/16) (d9225bbe417ba8a2d18d740f537f3581) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f) 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@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f) 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@243edafa) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f) [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 MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) aeb4c285986b611a400d50d8e4e8ecd0.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (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@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77) [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$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) 7c681c7a5fd34dd211c6bc57325ca0db.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77) [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$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) b85b4a5aab859beb272e98a214cd2d9f.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (10/16) (aeb4c285986b611a400d50d8e4e8ecd0) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77) [DEPLOYING].
[MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16) (b2033955e2b965559b68eac9913305c8) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16) (b2033955e2b965559b68eac9913305c8).
[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$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) 96e0313ef47d44116095942758680e55.
[MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16) (b2033955e2b965559b68eac9913305c8) [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 MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) a348d658884316123d2c12fa1395b39e.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (9/16) (7c681c7a5fd34dd211c6bc57325ca0db) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (6/16) (b85b4a5aab859beb272e98a214cd2d9f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16) (96e0313ef47d44116095942758680e55) switched from RUNNING to 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@243edafa) fdf796cb43ac26011c55078e6594c2f4.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (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@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77) [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 MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) 6ea8acc3c4ff8d331294550290e950fa.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (3/16) (a348d658884316123d2c12fa1395b39e) 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@243edafa) (16/16) (fdf796cb43ac26011c55078e6594c2f4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (1/16) (6ea8acc3c4ff8d331294550290e950fa) 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@3c6f5370) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7) 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@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad) 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@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) 33e98ea5866136d66acb717b75a41e8b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (4/16) (33e98ea5866136d66acb717b75a41e8b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) 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$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) 101a8a2b13f62cdc54e1694c46f91d69.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) [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@3c6f5370) ee573fc9319dc8f9d83551669baa7072.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$113/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16) (101a8a2b13f62cdc54e1694c46f91d69) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) 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@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676) 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@243edafa) (7/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (13/16) (ee573fc9319dc8f9d83551669baa7072) 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@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (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@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) faf9808b3f4843973b6b8a826ae8145f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) b2033955e2b965559b68eac9913305c8.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (8/16) (faf9808b3f4843973b6b8a826ae8145f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$115/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (14/16) (b2033955e2b965559b68eac9913305c8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) 6d5686ea6d5a4ecb9a56984ff2710b77.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534).
[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@3c6f5370) 616c4f999fd49dd9d80f00a8a3fd5590.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (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@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) [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@3c6f5370) ccafc13a6e00f954798425509042a881.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) (10/16) (6d5686ea6d5a4ecb9a56984ff2710b77) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) c4ed8715e67ba1ce603de2e4ef420ba7.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) 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 DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) 7e9462cad6114cf7c0505dd65145f0e7.
[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@3c6f5370) 31f92af799eb6544d4985182f45a54ad.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (9/16) (616c4f999fd49dd9d80f00a8a3fd5590) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) 0b5f71740bbd7a254b03cd5c5fc5b950.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (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@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) [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@3c6f5370) dbac272cfb33752a344ca9f08f170676.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (6/16) (ccafc13a6e00f954798425509042a881) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@243edafa) 58d9663a478d6ba60d69f6f5e1bbe534.
[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@3c6f5370) b16ae52b04f6dc9c37ad8c9ae1ff452c.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (7/16) (c4ed8715e67ba1ce603de2e4ef420ba7) 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@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3c6f5370) (3/16) (7e9462cad6114cf7c0505dd65145f0e7) 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@3c6f5370) (10/16) (31f92af799eb6544d4985182f45a54ad) 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@3c6f5370) (4/16) (0b5f71740bbd7a254b03cd5c5fc5b950) 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@3c6f5370) (1/16) (dbac272cfb33752a344ca9f08f170676) 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@243edafa) (7/16) (58d9663a478d6ba60d69f6f5e1bbe534) 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@3c6f5370) (14/16) (b16ae52b04f6dc9c37ad8c9ae1ff452c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job countingsourcetest0testboundedsourcesplits-jenkins-1116100931-2f75a50e (408f9214f328f94c3744b9f75168a5e7) switched from state RUNNING to 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.dispatcher.StandaloneDispatcher - Job 408f9214f328f94c3744b9f75168a5e7 reached globally terminal state FINISHED.
[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.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_132.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcherd8b01ad1-12b0-4e1f-81c6-b68a11906188.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherd8b01ad1-12b0-4e1f-81c6-b68a11906188.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job countingsourcetest0testboundedsourcesplits-jenkins-1116100931-2f75a50e(408f9214f328f94c3744b9f75168a5e7).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection b3adcf215fdc967155b53ddf8138fd87: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcActor - The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet. Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is started.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-c1739e0d-7b9e-4476-adf0-940d9ae78034
[flink-akka.actor.default-dispatcher-4] 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.TaskExecutor - JobManager for job 408f9214f328f94c3744b9f75168a5e7 with leader id a46eabd36269809379a5d72ebb664994 lost leadership.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcherd8b01ad1-12b0-4e1f-81c6-b68a11906188.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_132.
[flink-akka.actor.default-dispatcher-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:41249
[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 13583 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1116100931-2f75a50e_b548b0e0-6419-4c11-b740-1831723a38be/MANIFEST has 185 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1116100931-2f75a50e_b548b0e0-6419-4c11-b740-1831723a38be/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:42977
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:40729
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.transforms.ViewTest > testEmptyIterableSideInput SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 10,5,main]) completed. Took 24 mins 35.263 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 28m 0s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/fy5g2hbjvxcdy
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
#338
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/338/display/redirect>
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org