See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/177/display/redirect?page=changes>
Changes:
[lcwik] [BEAM-5919] Exclude META-INF from validation of shaded jar files
------------------------------------------
[...truncated 501.68 MB...]
[jobmanager-future-thread-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (8240506d55b7918dffabc7419d700432) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (8240506d55b7918dffabc7419d700432).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(12/16) (fe3102016b90a39e89bc412177279612) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (733447e012467ebd500843884563aa41) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (15/16)
(491a54d7f3cdf02d11b9773fe5b18287) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (733447e012467ebd500843884563aa41).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (15/16)
(491a54d7f3cdf02d11b9773fe5b18287).
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (8240506d55b7918dffabc7419d700432) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (6/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (15/16)
(491a54d7f3cdf02d11b9773fe5b18287) [FINISHED]
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (733447e012467ebd500843884563aa41) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (15/16)
(491a54d7f3cdf02d11b9773fe5b18287) 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@4055b05b) (13/16)
(8a12b3cc6e341caa2fb0cd8443fcb557) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (13/16)
(8a12b3cc6e341caa2fb0cd8443fcb557) 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@4055b05b) (16/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (13/16)
(8a12b3cc6e341caa2fb0cd8443fcb557).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (13/16)
(8a12b3cc6e341caa2fb0cd8443fcb557) [FINISHED]
[jobmanager-future-thread-13] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) 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@4055b05b) (2/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (16/16)
(e06ebcce4a58a7579e4f0563710eac1f) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (16/16)
(e06ebcce4a58a7579e4f0563710eac1f) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(16/16) (e06ebcce4a58a7579e4f0563710eac1f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (11/16)
(63d5b168ddb80937950b34b6dc563806) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (11/16)
(63d5b168ddb80937950b34b6dc563806) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(11/16) (63d5b168ddb80937950b34b6dc563806) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (14/16).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
2d3a1a3253cf0bae1fecd2d9620312c7.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (14/16)
(1d6e66311446dca8565d114a78265fb5) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (14/16)
(1d6e66311446dca8565d114a78265fb5) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(14/16) (1d6e66311446dca8565d114a78265fb5) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (11/16)
(63d5b168ddb80937950b34b6dc563806) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (16/16)
(e06ebcce4a58a7579e4f0563710eac1f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (16/16)
(e06ebcce4a58a7579e4f0563710eac1f) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (11/16)
(63d5b168ddb80937950b34b6dc563806) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (14/16)
(1d6e66311446dca8565d114a78265fb5) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (14/16)
(1d6e66311446dca8565d114a78265fb5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(10/16) (2d3a1a3253cf0bae1fecd2d9620312c7) 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@4055b05b) (12/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (16/16)
(e06ebcce4a58a7579e4f0563710eac1f) 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@4055b05b) (11/16)
(63d5b168ddb80937950b34b6dc563806) 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@4055b05b) (14/16)
(1d6e66311446dca8565d114a78265fb5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
f0064ca676139ff346410b44f97a64a6.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (12/16)
(613dbcdb43cf7414386949f80a7d361d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (12/16)
(613dbcdb43cf7414386949f80a7d361d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(12/16) (613dbcdb43cf7414386949f80a7d361d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (1/16)
(f0064ca676139ff346410b44f97a64a6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (12/16)
(613dbcdb43cf7414386949f80a7d361d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (12/16)
(613dbcdb43cf7414386949f80a7d361d) 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@4055b05b) (12/16)
(613dbcdb43cf7414386949f80a7d361d) 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@4055b05b) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (11/16)
(63d5b168ddb80937950b34b6dc563806) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (14/16)
(1d6e66311446dca8565d114a78265fb5) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (16/16)
(e06ebcce4a58a7579e4f0563710eac1f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (11/16)
(63d5b168ddb80937950b34b6dc563806).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (14/16)
(1d6e66311446dca8565d114a78265fb5).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (12/16)
(613dbcdb43cf7414386949f80a7d361d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (12/16)
(613dbcdb43cf7414386949f80a7d361d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (11/16)
(63d5b168ddb80937950b34b6dc563806) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (14/16)
(1d6e66311446dca8565d114a78265fb5) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (16/16)
(e06ebcce4a58a7579e4f0563710eac1f).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (12/16)
(613dbcdb43cf7414386949f80a7d361d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (16/16)
(e06ebcce4a58a7579e4f0563710eac1f) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
df31fedd4fff44d6acf738b1fb2effca.
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
638091231001f0571ccd6a372d317d7a.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (df31fedd4fff44d6acf738b1fb2effca) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (10/16)
(e3df953a7865e47cad5d300fd177c9ef) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (10/16)
(e3df953a7865e47cad5d300fd177c9ef) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (8/16)
(638091231001f0571ccd6a372d317d7a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(10/16) (e3df953a7865e47cad5d300fd177c9ef) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
736e9a6b4fd1bee76be2910efe2d2f55.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (9/16)
(f4f22ce203f00d51234e2b0e36f6c859) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (9/16)
(f4f22ce203f00d51234e2b0e36f6c859) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(9/16) (f4f22ce203f00d51234e2b0e36f6c859) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
4c557a3fb03bc13af363f5d64ae4a020.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (10/16)
(e3df953a7865e47cad5d300fd177c9ef) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
caeb2a7e5489a5b890db5a7b753f1894.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (10/16)
(e3df953a7865e47cad5d300fd177c9ef) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (9/16)
(f4f22ce203f00d51234e2b0e36f6c859) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (9/16)
(f4f22ce203f00d51234e2b0e36f6c859) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16) (736e9a6b4fd1bee76be2910efe2d2f55) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (4c557a3fb03bc13af363f5d64ae4a020) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (4/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (10/16)
(e3df953a7865e47cad5d300fd177c9ef) 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@4055b05b) (3/16)
(caeb2a7e5489a5b890db5a7b753f1894) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (4/16)
(d01ebad5b0e657235b1b38668297d473) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (9/16)
(f4f22ce203f00d51234e2b0e36f6c859) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(9/16) (f4f22ce203f00d51234e2b0e36f6c859).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (10/16)
(e3df953a7865e47cad5d300fd177c9ef) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (4/16)
(d01ebad5b0e657235b1b38668297d473) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (10/16)
(e3df953a7865e47cad5d300fd177c9ef).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (9/16)
(f4f22ce203f00d51234e2b0e36f6c859) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(4/16) (d01ebad5b0e657235b1b38668297d473) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (9/16)
(f4f22ce203f00d51234e2b0e36f6c859) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (10/16)
(e3df953a7865e47cad5d300fd177c9ef) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (7/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
0aeeac8185df5359db13f14cc1900c73.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (7/16)
(e68a848b94a9fac952f5bc834f1f9887) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
8240506d55b7918dffabc7419d700432.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (7/16)
(e68a848b94a9fac952f5bc834f1f9887) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (4/16)
(d01ebad5b0e657235b1b38668297d473) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(7/16) (e68a848b94a9fac952f5bc834f1f9887) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (4/16)
(d01ebad5b0e657235b1b38668297d473) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (0aeeac8185df5359db13f14cc1900c73) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (7/16)
(e68a848b94a9fac952f5bc834f1f9887) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (7/16)
(e68a848b94a9fac952f5bc834f1f9887) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (6/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (8240506d55b7918dffabc7419d700432) 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@4055b05b) (4/16)
(d01ebad5b0e657235b1b38668297d473) 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@4055b05b) (7/16)
(e68a848b94a9fac952f5bc834f1f9887) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
733447e012467ebd500843884563aa41.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (7/16)
(e68a848b94a9fac952f5bc834f1f9887) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
491a54d7f3cdf02d11b9773fe5b18287.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (4/16)
(d01ebad5b0e657235b1b38668297d473) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(7/16) (e68a848b94a9fac952f5bc834f1f9887).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(4/16) (d01ebad5b0e657235b1b38668297d473).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (7/16)
(e68a848b94a9fac952f5bc834f1f9887) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (4/16)
(d01ebad5b0e657235b1b38668297d473) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (733447e012467ebd500843884563aa41) 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@4055b05b) (15/16)
(491a54d7f3cdf02d11b9773fe5b18287) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(6/16) (7ed6e74d9924972f8c0d9899b9f2883f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16) (658ee560012bf743837a1e52093284bb) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
8a12b3cc6e341caa2fb0cd8443fcb557.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16) (7df102bb2c74be65e1cd97517cc2ac80) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
63d5b168ddb80937950b34b6dc563806.
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
1d6e66311446dca8565d114a78265fb5.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (13/16)
(8a12b3cc6e341caa2fb0cd8443fcb557) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
613dbcdb43cf7414386949f80a7d361d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
e06ebcce4a58a7579e4f0563710eac1f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16) (658ee560012bf743837a1e52093284bb).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(6/16) (7ed6e74d9924972f8c0d9899b9f2883f).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
f4f22ce203f00d51234e2b0e36f6c859.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(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@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) 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@4055b05b) (11/16)
(63d5b168ddb80937950b34b6dc563806) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16) (7df102bb2c74be65e1cd97517cc2ac80).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
e3df953a7865e47cad5d300fd177c9ef.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (14/16)
(1d6e66311446dca8565d114a78265fb5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b)
e68a848b94a9fac952f5bc834f1f9887.
[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@4055b05b)
d01ebad5b0e657235b1b38668297d473.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) 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@4055b05b) (12/16)
(613dbcdb43cf7414386949f80a7d361d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
658ee560012bf743837a1e52093284bb.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (16/16)
(e06ebcce4a58a7579e4f0563710eac1f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
7ed6e74d9924972f8c0d9899b9f2883f.
[flink-akka.actor.default-dispatcher-2] 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@4055b05b)
7df102bb2c74be65e1cd97517cc2ac80.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4055b05b) (9/16)
(f4f22ce203f00d51234e2b0e36f6c859) 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@4055b05b) (10/16)
(e3df953a7865e47cad5d300fd177c9ef) 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@4055b05b) (7/16)
(e68a848b94a9fac952f5bc834f1f9887) 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@4055b05b) (4/16)
(d01ebad5b0e657235b1b38668297d473) 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@4055b05b) (5/16)
(658ee560012bf743837a1e52093284bb) 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@4055b05b) (6/16)
(7ed6e74d9924972f8c0d9899b9f2883f) 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@4055b05b) (2/16)
(7df102bb2c74be65e1cd97517cc2ac80) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1031232823-a62c5832
(113bb6d5f014781cbbffc2c03783273e) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
113bb6d5f014781cbbffc2c03783273e reached globally terminal state FINISHED.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher4b3cc646-083a-42c5-a5f9-201e2b0d497d.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher4b3cc646-083a-42c5-a5f9-201e2b0d497d.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_242.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1031232823-a62c5832(113bb6d5f014781cbbffc2c03783273e).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister
TaskManager f7307708f98216e9d4c8b99feecf0573 from the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
49173571f7a86aedcadbe5d06d6f48bd: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
113bb6d5f014781cbbffc2c03783273e with leader id
a77228fb3fc57f8d2dab371f18974694 lost leadership.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-7d9298e3-0a1e-4b5e-bc89-2dcf552d6650
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_242.
[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/dispatcher4b3cc646-083a-42c5-a5f9-201e2b0d497d.
[ForkJoinPool.commonPool-worker-4] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-4] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:46813
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner -
Execution finished in 11162 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1031232823-a62c5832_a4e2ecf0-ec5c-4be5-8d36-b1520764dcec/MANIFEST
has 185 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1031232823-a62c5832_a4e2ecf0-ec5c-4be5-8d36-b1520764dcec/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:44339
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:37367
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
187 tests completed, 1 failed, 1 skipped
Finished generating test XML results (3.027 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunner>
Generating HTML test report...
Finished generating test html results (1.768 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker
for ':' Thread 8,5,main]) completed. Took 43 mins 27.775 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 46m 52s
76 actionable tasks: 75 executed, 1 up-to-date
Publishing build scan...
https://gradle.com/s/mqjxz2s6o77fu
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org
