See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/137/display/redirect>
------------------------------------------
[...truncated 501.27 MB...]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (14/16)
(878f40a4e6c3f5ce362f888ac6b04dc7) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(14/16) (878f40a4e6c3f5ce362f888ac6b04dc7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (15/16)
(f7167ecb8cf873bb7f4d7372aebaa109) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (14/16)
(878f40a4e6c3f5ce362f888ac6b04dc7) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
629195e652b3219ed7a7afa1d3668124.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (15/16)
(f7167ecb8cf873bb7f4d7372aebaa109) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (14/16)
(878f40a4e6c3f5ce362f888ac6b04dc7) 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@3efea62d) (14/16)
(878f40a4e6c3f5ce362f888ac6b04dc7) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (13/16)
(261cae3c5b1219cc99c50fd03625464c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (13/16)
(261cae3c5b1219cc99c50fd03625464c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (15/16)
(f7167ecb8cf873bb7f4d7372aebaa109) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(13/16) (261cae3c5b1219cc99c50fd03625464c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (14/16)
(878f40a4e6c3f5ce362f888ac6b04dc7) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (14/16)
(878f40a4e6c3f5ce362f888ac6b04dc7).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (14/16)
(878f40a4e6c3f5ce362f888ac6b04dc7) [FINISHED]
[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) (629195e652b3219ed7a7afa1d3668124) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (15/16)
(f7167ecb8cf873bb7f4d7372aebaa109).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (13/16)
(261cae3c5b1219cc99c50fd03625464c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (13/16)
(261cae3c5b1219cc99c50fd03625464c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (15/16)
(f7167ecb8cf873bb7f4d7372aebaa109) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (12/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (13/16)
(261cae3c5b1219cc99c50fd03625464c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (13/16)
(261cae3c5b1219cc99c50fd03625464c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (13/16)
(261cae3c5b1219cc99c50fd03625464c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (13/16)
(261cae3c5b1219cc99c50fd03625464c) [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@3efea62d)
0f9f6fd5cd5ed6be04eefb393181be23.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (12/16)
(4dacba8965d41c84e29ae89ed5e01c65) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (12/16)
(4dacba8965d41c84e29ae89ed5e01c65) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(12/16) (4dacba8965d41c84e29ae89ed5e01c65) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
b15792fda8abd1a68ec518dced85fa3f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (12/16)
(4dacba8965d41c84e29ae89ed5e01c65) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
bc42e1f9eb5fb9af162e38be18094c8d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (12/16)
(4dacba8965d41c84e29ae89ed5e01c65) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (ee60483838876b20413536a7de7bc246) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/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)
(4/16) (ee60483838876b20413536a7de7bc246).
[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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
9c29b8507a88d8df9770a3a63eb0fc19.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/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)
(4/16) (ee60483838876b20413536a7de7bc246) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
a942a3b49bc8770b5d46572ebb06ba76.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (89663afe82360e9714b1f8f23eebe1ce) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/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)
(11/16) (89663afe82360e9714b1f8f23eebe1ce).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (12/16)
(4dacba8965d41c84e29ae89ed5e01c65) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (12/16)
(4dacba8965d41c84e29ae89ed5e01c65).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (3/16)
(0f9f6fd5cd5ed6be04eefb393181be23) 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@3efea62d)
0796a8685fc3454e0cdb9df3e40cf5e3.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (12/16)
(4dacba8965d41c84e29ae89ed5e01c65) [FINISHED]
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/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)
(11/16) (89663afe82360e9714b1f8f23eebe1ce) [FINISHED]
[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) (65bad11eeb8a2ea5f690291c64ec975a) 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) (65bad11eeb8a2ea5f690291c64ec975a).
[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) (65bad11eeb8a2ea5f690291c64ec975a) [FINISHED]
[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)
(7/16) (b15792fda8abd1a68ec518dced85fa3f) 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@3efea62d) (12/16)
(4dacba8965d41c84e29ae89ed5e01c65) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-14] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (7/16).
[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)
(10/16) (bc42e1f9eb5fb9af162e38be18094c8d) 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@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) switched from SCHEDULED to 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) (9c29b8507a88d8df9770a3a63eb0fc19) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (4/16) (attempt
#0) to localhost
[jobmanager-future-thread-11] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) switched from CREATED to SCHEDULED.
[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) (a942a3b49bc8770b5d46572ebb06ba76) 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@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) 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@3efea62d) (11/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (7/16)
(bc50b8f8b4eed4fc8096680e403dd03b) switched from CREATED to DEPLOYING.
[jobmanager-future-thread-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (16/16)
(0796a8685fc3454e0cdb9df3e40cf5e3) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (7/16)
(bc50b8f8b4eed4fc8096680e403dd03b) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(7/16) (bc50b8f8b4eed4fc8096680e403dd03b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (10/16)
(7c7d81c3d3cd302625d0bdaadaf527e2) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (10/16)
(7c7d81c3d3cd302625d0bdaadaf527e2) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (7/16)
(bc50b8f8b4eed4fc8096680e403dd03b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(10/16) (7c7d81c3d3cd302625d0bdaadaf527e2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (7/16)
(bc50b8f8b4eed4fc8096680e403dd03b) 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@3efea62d) (7/16)
(bc50b8f8b4eed4fc8096680e403dd03b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (10/16)
(7c7d81c3d3cd302625d0bdaadaf527e2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (10/16)
(7c7d81c3d3cd302625d0bdaadaf527e2) 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@3efea62d) (10/16)
(7c7d81c3d3cd302625d0bdaadaf527e2) 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@3efea62d) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (9/16)
(edc71ab0769f3fd34f64ba8ffc56873d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (9/16)
(edc71ab0769f3fd34f64ba8ffc56873d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(9/16) (edc71ab0769f3fd34f64ba8ffc56873d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (10/16)
(7c7d81c3d3cd302625d0bdaadaf527e2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (10/16)
(7c7d81c3d3cd302625d0bdaadaf527e2).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (10/16)
(7c7d81c3d3cd302625d0bdaadaf527e2) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (7/16)
(bc50b8f8b4eed4fc8096680e403dd03b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(7/16) (bc50b8f8b4eed4fc8096680e403dd03b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (7/16)
(bc50b8f8b4eed4fc8096680e403dd03b) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (9/16)
(edc71ab0769f3fd34f64ba8ffc56873d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (9/16)
(edc71ab0769f3fd34f64ba8ffc56873d) 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@3efea62d) (9/16)
(edc71ab0769f3fd34f64ba8ffc56873d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
1022dc4777a9b8fa04cb650627772494.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (9/16)
(edc71ab0769f3fd34f64ba8ffc56873d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(9/16) (edc71ab0769f3fd34f64ba8ffc56873d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (2/16)
(a066593f910bf8a394430d6df205cb52) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (2/16)
(a066593f910bf8a394430d6df205cb52) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (9/16)
(edc71ab0769f3fd34f64ba8ffc56873d) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16) (1022dc4777a9b8fa04cb650627772494) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(2/16) (a066593f910bf8a394430d6df205cb52) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (1/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
090482876049f79bf3d1e54b173423b4.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (1/16)
(ddade2c91dd7f7c112db9ad997548e56) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (1/16)
(ddade2c91dd7f7c112db9ad997548e56) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(1/16) (ddade2c91dd7f7c112db9ad997548e56) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
878f40a4e6c3f5ce362f888ac6b04dc7.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
f7167ecb8cf873bb7f4d7372aebaa109.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
261cae3c5b1219cc99c50fd03625464c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (1/16)
(ddade2c91dd7f7c112db9ad997548e56) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (2/16)
(a066593f910bf8a394430d6df205cb52) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
ee60483838876b20413536a7de7bc246.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
4dacba8965d41c84e29ae89ed5e01c65.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (1/16)
(ddade2c91dd7f7c112db9ad997548e56) 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@3efea62d) (8/16)
(090482876049f79bf3d1e54b173423b4) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (2/16)
(a066593f910bf8a394430d6df205cb52) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
89663afe82360e9714b1f8f23eebe1ce.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
65bad11eeb8a2ea5f690291c64ec975a.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (14/16)
(878f40a4e6c3f5ce362f888ac6b04dc7) 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@3efea62d) (15/16)
(f7167ecb8cf873bb7f4d7372aebaa109) 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@3efea62d) (13/16)
(261cae3c5b1219cc99c50fd03625464c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (ee60483838876b20413536a7de7bc246) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (1/16)
(ddade2c91dd7f7c112db9ad997548e56) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (2/16)
(a066593f910bf8a394430d6df205cb52) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(1/16) (ddade2c91dd7f7c112db9ad997548e56).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(2/16) (a066593f910bf8a394430d6df205cb52).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (2/16)
(a066593f910bf8a394430d6df205cb52) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (4/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (1/16)
(ddade2c91dd7f7c112db9ad997548e56) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (1/16)
(ddade2c91dd7f7c112db9ad997548e56) 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@3efea62d) (12/16)
(4dacba8965d41c84e29ae89ed5e01c65) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (89663afe82360e9714b1f8f23eebe1ce) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (2/16)
(a066593f910bf8a394430d6df205cb52) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (65bad11eeb8a2ea5f690291c64ec975a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(4/16) (619689086ab10faf05672674d4e785e2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(11/16) (ba6fdcb18758431f5447e2fc64db3629) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
7c7d81c3d3cd302625d0bdaadaf527e2.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(5/16) (f2ae1416bc8ce221147d38591439096a) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
bc50b8f8b4eed4fc8096680e403dd03b.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
edc71ab0769f3fd34f64ba8ffc56873d.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (10/16)
(7c7d81c3d3cd302625d0bdaadaf527e2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
ddade2c91dd7f7c112db9ad997548e56.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(4/16) (619689086ab10faf05672674d4e785e2).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
a066593f910bf8a394430d6df205cb52.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (7/16)
(bc50b8f8b4eed4fc8096680e403dd03b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(5/16) (f2ae1416bc8ce221147d38591439096a).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d)
(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@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) [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@3efea62d)
619689086ab10faf05672674d4e785e2.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (9/16)
(edc71ab0769f3fd34f64ba8ffc56873d) 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@3efea62d)
ba6fdcb18758431f5447e2fc64db3629.
[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@3efea62d)
f2ae1416bc8ce221147d38591439096a.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) 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@3efea62d) (1/16)
(ddade2c91dd7f7c112db9ad997548e56) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (2/16)
(a066593f910bf8a394430d6df205cb52) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (4/16)
(619689086ab10faf05672674d4e785e2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (11/16)
(ba6fdcb18758431f5447e2fc64db3629) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3efea62d) (5/16)
(f2ae1416bc8ce221147d38591439096a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1027184702-66fcec43
(a98082e73ecef6483358d7e2c074f438) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
a98082e73ecef6483358d7e2c074f438 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-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher5b47d129-59a9-4ad8-b576-4b83da656d2a.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher5b47d129-59a9-4ad8-b576-4b83da656d2a.
[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-1027184702-66fcec43(a98082e73ecef6483358d7e2c074f438).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister
TaskManager f5b518d1e027a2b3447fb45b6bd01051 from the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
be94b1ac581f05555089bdc1c6bfc403: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] 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-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
a98082e73ecef6483358d7e2c074f438 with leader id
853d6ddb26eefe5c259781225cfe4985 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/dispatcher5b47d129-59a9-4ad8-b576-4b83da656d2a.
[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-e78b362c-a34b-419c-ad4c-f54b5622114a
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[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-7] 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:39659
[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 12709 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1027184702-66fcec43_1fbefa94-dc75-483a-b424-d30bb4e0b884/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-1027184702-66fcec43_1fbefa94-dc75-483a-b424-d30bb4e0b884/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:39433
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:37797
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.617 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.892 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 3,5,main]) completed. Took 43 mins 47.159 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 47m 26s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/arphhyr6jqcmy
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]
