See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/230/display/redirect>
------------------------------------------
[...truncated 479.26 MB...]
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(16/16) (ed553fae380d990bb9f876e9613a49f8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16) (47edf11b8430af3e1adac747a9883736) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(16/16) (ed553fae380d990bb9f876e9613a49f8).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (5/16).
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(16/16) (ed553fae380d990bb9f876e9613a49f8) [FINISHED]
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (eea462389cc7d6e7b9415618e1626407) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (ca286059766a937b6ae19e5ea5348287) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (8/16)
(2d239e86c00b3a19d8ffd481a2083ae2) [DEPLOYING].
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (eea462389cc7d6e7b9415618e1626407).
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (ca286059766a937b6ae19e5ea5348287).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
bd5274a0267ea462dbf6e152019b5376.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (8/16)
(2d239e86c00b3a19d8ffd481a2083ae2) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (ca286059766a937b6ae19e5ea5348287) [FINISHED]
[jobmanager-future-thread-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16) (bd5274a0267ea462dbf6e152019b5376) 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@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) 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@58ad1862) (16/16) (attempt
#0) to localhost
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (eea462389cc7d6e7b9415618e1626407) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (1/16).
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (5/16)
(2f60097f81236ad89e870fa3b05cb488) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (5/16)
(2f60097f81236ad89e870fa3b05cb488) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) 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@58ad1862) (4/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (8/16)
(2d239e86c00b3a19d8ffd481a2083ae2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(8/16) (2d239e86c00b3a19d8ffd481a2083ae2).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (8/16)
(2d239e86c00b3a19d8ffd481a2083ae2) [FINISHED]
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (990f9e9249e17a0400abff869045a719) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (990f9e9249e17a0400abff869045a719).
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (990f9e9249e17a0400abff869045a719) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (8/16)
(2d239e86c00b3a19d8ffd481a2083ae2) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (1/16)
(9d022b68beecded1afd2f37581093d13) switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (719b4570b272b492da93c875baf016f4) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (1/16)
(9d022b68beecded1afd2f37581093d13) [DEPLOYING]
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (719b4570b272b492da93c875baf016f4).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(1/16) (9d022b68beecded1afd2f37581093d13) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(5/16) (2f60097f81236ad89e870fa3b05cb488) [DEPLOYING].
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (719b4570b272b492da93c875baf016f4) [FINISHED]
[jobmanager-future-thread-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (5/16)
(2f60097f81236ad89e870fa3b05cb488) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (1/16)
(9d022b68beecded1afd2f37581093d13) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (5/16)
(2f60097f81236ad89e870fa3b05cb488) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (2/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (3/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (5/16)
(2f60097f81236ad89e870fa3b05cb488) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (1/16)
(9d022b68beecded1afd2f37581093d13) 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@58ad1862) (1/16)
(9d022b68beecded1afd2f37581093d13) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (5/16)
(2f60097f81236ad89e870fa3b05cb488) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (58f967e80cc06f5b3c006e2964b4e423) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(5/16) (2f60097f81236ad89e870fa3b05cb488).
[jobmanager-future-thread-15] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (5/16)
(2f60097f81236ad89e870fa3b05cb488) [FINISHED]
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (58f967e80cc06f5b3c006e2964b4e423).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
0a66678027cc1e3838d9b72bdcc5e6c6.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (1/16)
(9d022b68beecded1afd2f37581093d13) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (3/16)
(0d9720824cfe40ee5c8f95c58723d53c) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(1/16) (9d022b68beecded1afd2f37581093d13).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (3/16)
(0d9720824cfe40ee5c8f95c58723d53c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16) (0d9720824cfe40ee5c8f95c58723d53c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (1/16)
(9d022b68beecded1afd2f37581093d13) [FINISHED]
[MapPartition (MapPartition at
PAssert$125/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$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (58f967e80cc06f5b3c006e2964b4e423) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/16) (0a66678027cc1e3838d9b72bdcc5e6c6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (3/16)
(0d9720824cfe40ee5c8f95c58723d53c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (3/16)
(0d9720824cfe40ee5c8f95c58723d53c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (13/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (3/16)
(0d9720824cfe40ee5c8f95c58723d53c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
ed553fae380d990bb9f876e9613a49f8.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (3/16)
(0d9720824cfe40ee5c8f95c58723d53c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16) (0d9720824cfe40ee5c8f95c58723d53c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (13/16)
(7f39b2df207ffcbff663f7073bd7a640) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (13/16)
(7f39b2df207ffcbff663f7073bd7a640) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(13/16) (7f39b2df207ffcbff663f7073bd7a640) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (3/16)
(0d9720824cfe40ee5c8f95c58723d53c) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
ca286059766a937b6ae19e5ea5348287.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
eea462389cc7d6e7b9415618e1626407.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(16/16) (ed553fae380d990bb9f876e9613a49f8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (ca286059766a937b6ae19e5ea5348287) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (16/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (13/16)
(7f39b2df207ffcbff663f7073bd7a640) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (eea462389cc7d6e7b9415618e1626407) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (13/16)
(7f39b2df207ffcbff663f7073bd7a640) 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@58ad1862) (13/16)
(7f39b2df207ffcbff663f7073bd7a640) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (13/16)
(7f39b2df207ffcbff663f7073bd7a640) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (13/16)
(7f39b2df207ffcbff663f7073bd7a640).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (13/16)
(7f39b2df207ffcbff663f7073bd7a640) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(16/16) (17c7292bb8695dd017da1ed38f9c4e26) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(14/16) (938cf7bd3c5cfbd66134332ba133b4ae) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (4/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
2d239e86c00b3a19d8ffd481a2083ae2.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(4/16) (4aebdbbac0fbdd8625483dfd1d8c94df) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
990f9e9249e17a0400abff869045a719.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
719b4570b272b492da93c875baf016f4.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (8/16)
(2d239e86c00b3a19d8ffd481a2083ae2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (990f9e9249e17a0400abff869045a719) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (719b4570b272b492da93c875baf016f4) 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@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(4/16) (4aebdbbac0fbdd8625483dfd1d8c94df).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(15/16) (796c516529303b4977ca9d84fc9f1d01) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
2f60097f81236ad89e870fa3b05cb488.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(2/16) (62fa6e62d24aeb1e5758de86d52cbee4) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (5/16)
(2f60097f81236ad89e870fa3b05cb488) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
9d022b68beecded1afd2f37581093d13.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(11/16) (b555d6f074e3f706adf5eece5402ffc8) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
58f967e80cc06f5b3c006e2964b4e423.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
0d9720824cfe40ee5c8f95c58723d53c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (1/16)
(9d022b68beecded1afd2f37581093d13) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(2/16) (62fa6e62d24aeb1e5758de86d52cbee4).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
7f39b2df207ffcbff663f7073bd7a640.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
938cf7bd3c5cfbd66134332ba133b4ae.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
(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@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
17c7292bb8695dd017da1ed38f9c4e26.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$125/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(11/16) (58f967e80cc06f5b3c006e2964b4e423) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
4aebdbbac0fbdd8625483dfd1d8c94df.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) 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@58ad1862)
62fa6e62d24aeb1e5758de86d52cbee4.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (3/16)
(0d9720824cfe40ee5c8f95c58723d53c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862)
796c516529303b4977ca9d84fc9f1d01.
[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@58ad1862)
b555d6f074e3f706adf5eece5402ffc8.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@58ad1862) (13/16)
(7f39b2df207ffcbff663f7073bd7a640) 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@58ad1862) (14/16)
(938cf7bd3c5cfbd66134332ba133b4ae) 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@58ad1862) (16/16)
(17c7292bb8695dd017da1ed38f9c4e26) 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@58ad1862) (4/16)
(4aebdbbac0fbdd8625483dfd1d8c94df) 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@58ad1862) (2/16)
(62fa6e62d24aeb1e5758de86d52cbee4) 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@58ad1862) (15/16)
(796c516529303b4977ca9d84fc9f1d01) 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@58ad1862) (11/16)
(b555d6f074e3f706adf5eece5402ffc8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1106124129-64e2ff05
(f7fe34c64c2a332f8f046d8b61fa1902) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
f7fe34c64c2a332f8f046d8b61fa1902 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.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_212.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherbc4e5bed-0d85-44a1-95b0-c142aa37ab6e.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherbc4e5bed-0d85-44a1-95b0-c142aa37ab6e.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1106124129-64e2ff05(f7fe34c64c2a332f8f046d8b61fa1902).
[flink-akka.actor.default-dispatcher-5] 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-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
bb19cf3dac870e3709525b9b052e1021: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-4a1306fc-967b-40ae-baf6-1b487b58c2c0
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.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-6] 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
f7fe34c64c2a332f8f046d8b61fa1902 with leader id
98ed8c027a1c186508cd8b0f07f94b06 lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcherbc4e5bed-0d85-44a1-95b0-c142aa37ab6e.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_212.
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:38505
[flink-akka.actor.default-dispatcher-7] 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 12324 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1106124129-64e2ff05_8aa5efc9-50ad-4ac9-960b-785a5fb3b105/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-1106124129-64e2ff05_8aa5efc9-50ad-4ac9-960b-785a5fb3b105/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:46497
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:42643
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.io.CountingSourceTest > testUnboundedSourceSplits SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Daemon
worker,5,main]) completed. Took 38 mins 46.37 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> Process 'Gradle Test Executor 2' finished with non-zero exit value 137
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at
https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 41m 48s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/buuz4auj2jguw
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
