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: [email protected]
For additional commands, e-mail: [email protected]
