See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/12/display/redirect>
------------------------------------------
[...truncated 356.89 MB...]
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (dd312ed5a954a19b8bd7739fecb81009).
[jobmanager-future-thread-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (dd312ed5a954a19b8bd7739fecb81009) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (5/16)
(5ca12e4cde18995148393c42ccccbcfd) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (5/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (7/16)
(c0ff349588fd095d8670a9d75b40c332) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (7/16)
(c0ff349588fd095d8670a9d75b40c332) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (2/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(7/16) (c0ff349588fd095d8670a9d75b40c332) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (7/16)
(c0ff349588fd095d8670a9d75b40c332) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (7/16)
(c0ff349588fd095d8670a9d75b40c332) 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@4edfa873) (7/16)
(c0ff349588fd095d8670a9d75b40c332) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (13/16)
(8ac5be2bbb2830ea852c2c0956507741) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (7/16)
(c0ff349588fd095d8670a9d75b40c332) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(7/16) (c0ff349588fd095d8670a9d75b40c332).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (13/16)
(8ac5be2bbb2830ea852c2c0956507741) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (7/16)
(c0ff349588fd095d8670a9d75b40c332) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(13/16) (8ac5be2bbb2830ea852c2c0956507741) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (12/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (13/16)
(8ac5be2bbb2830ea852c2c0956507741) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (13/16)
(8ac5be2bbb2830ea852c2c0956507741) 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@4edfa873) (13/16)
(8ac5be2bbb2830ea852c2c0956507741) 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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
bd9b8223c5082212dcb6241eb8663946.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (12/16)
(63229d0480a30e203e7ee621b6acc803) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (12/16)
(63229d0480a30e203e7ee621b6acc803) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(12/16) (63229d0480a30e203e7ee621b6acc803) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (13/16)
(8ac5be2bbb2830ea852c2c0956507741) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (13/16)
(8ac5be2bbb2830ea852c2c0956507741).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (13/16)
(8ac5be2bbb2830ea852c2c0956507741) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (bd9b8223c5082212dcb6241eb8663946) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (12/16)
(63229d0480a30e203e7ee621b6acc803) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (12/16)
(63229d0480a30e203e7ee621b6acc803) 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@4edfa873) (12/16)
(63229d0480a30e203e7ee621b6acc803) 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@4edfa873) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (12/16)
(63229d0480a30e203e7ee621b6acc803) 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 MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
fd0b80894245be660be2651c685c36ec.
[jobmanager-future-thread-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (12/16)
(63229d0480a30e203e7ee621b6acc803).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (6/16)
(10a88f41649bc48640a22a8bc12c271a) switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (1e87346161692db69ffa22082738bc4a) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (1e87346161692db69ffa22082738bc4a).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (6/16)
(10a88f41649bc48640a22a8bc12c271a) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16) (10a88f41649bc48640a22a8bc12c271a) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (12/16)
(63229d0480a30e203e7ee621b6acc803) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) switched from SCHEDULED to DEPLOYING.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16) (ffbbc857da6c2289b4de4ca8ce1a3c3c) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (1e87346161692db69ffa22082738bc4a) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (4/16) (attempt
#0) to localhost
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16) (ffbbc857da6c2289b4de4ca8ce1a3c3c).
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(14/16) (fd0b80894245be660be2651c685c36ec) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (3645fb61b92d2feaf2add31d1a49cfaf) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (3645fb61b92d2feaf2add31d1a49cfaf).
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16) (ffbbc857da6c2289b4de4ca8ce1a3c3c) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (6/16)
(10a88f41649bc48640a22a8bc12c271a) [DEPLOYING].
[MapPartition (MapPartition at
PAssert$155/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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (3645fb61b92d2feaf2add31d1a49cfaf) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (6/16)
(10a88f41649bc48640a22a8bc12c271a) 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@4edfa873) (6/16)
(10a88f41649bc48640a22a8bc12c271a) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-12] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-12] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) 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@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (6/16)
(10a88f41649bc48640a22a8bc12c271a) 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@4edfa873) (15/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16) (10a88f41649bc48640a22a8bc12c271a).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (6/16)
(10a88f41649bc48640a22a8bc12c271a) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (1/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@4edfa873) (14/16).
[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@4edfa873)
d949dfca0c33aa15217a7fba1778a4f3.
[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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
ff57731ef2fc78b7fb2115ac27f7b212.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (14/16)
(36f83eb7911d3da50d18c15f48515c1c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (14/16)
(36f83eb7911d3da50d18c15f48515c1c) [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@4edfa873)
c22c9d3f1466e7cd93f8907a6103493c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(14/16) (36f83eb7911d3da50d18c15f48515c1c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (8/16)
(d949dfca0c33aa15217a7fba1778a4f3) 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 MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
dd312ed5a954a19b8bd7739fecb81009.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (14/16)
(36f83eb7911d3da50d18c15f48515c1c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(5/16) (ff57731ef2fc78b7fb2115ac27f7b212) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (14/16)
(36f83eb7911d3da50d18c15f48515c1c) 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@4edfa873) (10/16)
(c22c9d3f1466e7cd93f8907a6103493c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (14/16)
(36f83eb7911d3da50d18c15f48515c1c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (14/16)
(36f83eb7911d3da50d18c15f48515c1c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (14/16)
(36f83eb7911d3da50d18c15f48515c1c) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (5/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (dd312ed5a954a19b8bd7739fecb81009) 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@4edfa873) (14/16)
(36f83eb7911d3da50d18c15f48515c1c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (5/16)
(5ca12e4cde18995148393c42ccccbcfd) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (5/16)
(5ca12e4cde18995148393c42ccccbcfd) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(5/16) (5ca12e4cde18995148393c42ccccbcfd) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (5/16)
(5ca12e4cde18995148393c42ccccbcfd) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (5/16)
(5ca12e4cde18995148393c42ccccbcfd) 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@4edfa873) (5/16)
(5ca12e4cde18995148393c42ccccbcfd) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (4c3c4e70c497d74d52fc3e26cdc5a601) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (4c3c4e70c497d74d52fc3e26cdc5a601).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (5/16)
(5ca12e4cde18995148393c42ccccbcfd) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(5/16) (5ca12e4cde18995148393c42ccccbcfd).
[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@4edfa873)
c0ff349588fd095d8670a9d75b40c332.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (4c3c4e70c497d74d52fc3e26cdc5a601) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (5/16)
(5ca12e4cde18995148393c42ccccbcfd) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
8ac5be2bbb2830ea852c2c0956507741.
[jobmanager-future-thread-14] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) 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@4edfa873) (7/16)
(c0ff349588fd095d8670a9d75b40c332) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) 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@4edfa873) (9/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
63229d0480a30e203e7ee621b6acc803.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (13/16)
(8ac5be2bbb2830ea852c2c0956507741) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
1e87346161692db69ffa22082738bc4a.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(2/16) (0d40d358c2743dd029e9cb263433654e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (12/16)
(63229d0480a30e203e7ee621b6acc803) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (4/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(4/16) (1e87346161692db69ffa22082738bc4a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) 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@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
ffbbc857da6c2289b4de4ca8ce1a3c3c.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
3645fb61b92d2feaf2add31d1a49cfaf.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(4/16) (77cb9defb6a66652b01ff86a2e1c1de6) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16) (ffbbc857da6c2289b4de4ca8ce1a3c3c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (3645fb61b92d2feaf2add31d1a49cfaf) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) 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@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (15/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(2/16) (0d40d358c2743dd029e9cb263433654e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(4/16) (77cb9defb6a66652b01ff86a2e1c1de6).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) [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@4edfa873)
10a88f41649bc48640a22a8bc12c271a.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (6/16)
(10a88f41649bc48640a22a8bc12c271a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(15/16) (1a92acbdb3d0033fcfdf391153041bda) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (1/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) [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@4edfa873)
36f83eb7911d3da50d18c15f48515c1c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(1/16) (65d523f62296ff0cc2043d7df9a8c56f) [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@4edfa873)
5ca12e4cde18995148393c42ccccbcfd.
[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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
4c3c4e70c497d74d52fc3e26cdc5a601.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (14/16)
(36f83eb7911d3da50d18c15f48515c1c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) 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@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) 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@4edfa873) (5/16)
(5ca12e4cde18995148393c42ccccbcfd) 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@4edfa873) (9/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (4c3c4e70c497d74d52fc3e26cdc5a601) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] 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@4edfa873)
0d40d358c2743dd029e9cb263433654e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(1/16) (65d523f62296ff0cc2043d7df9a8c56f).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(9/16) (8f8e000316141ca099bd33e6d0593450) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) [FINISHED]
[flink-akka.actor.default-dispatcher-3] 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@4edfa873)
77cb9defb6a66652b01ff86a2e1c1de6.
[flink-akka.actor.default-dispatcher-3] 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@4edfa873)
1a92acbdb3d0033fcfdf391153041bda.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (2/16)
(0d40d358c2743dd029e9cb263433654e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] 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@4edfa873)
65d523f62296ff0cc2043d7df9a8c56f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) 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@4edfa873) (4/16)
(77cb9defb6a66652b01ff86a2e1c1de6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(9/16) (8f8e000316141ca099bd33e6d0593450).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873)
(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@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) [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@4edfa873)
8f8e000316141ca099bd33e6d0593450.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@4edfa873) (15/16)
(1a92acbdb3d0033fcfdf391153041bda) 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@4edfa873) (1/16)
(65d523f62296ff0cc2043d7df9a8c56f) 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@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) 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@4edfa873) (9/16)
(8f8e000316141ca099bd33e6d0593450) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1125065444-48c571b
(0b30f04a739e9412b0a76fcd25eb53f5) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
0b30f04a739e9412b0a76fcd25eb53f5 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/dispatcher31e61979-6ee0-4f44-9359-2d6b3b4f4ea3.
[flink-akka.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher31e61979-6ee0-4f44-9359-2d6b3b4f4ea3.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1125065444-48c571b(0b30f04a739e9412b0a76fcd25eb53f5).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
dcfe8066b514e0dbcec26f1cf49dd3d9: 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.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
0b30f04a739e9412b0a76fcd25eb53f5 with leader id
8cece549a8dce5424ffc43b9b9c64396 lost leadership.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-870836ec-ae7c-4c0a-94e4-c7db503c9bdb
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher31e61979-6ee0-4f44-9359-2d6b3b4f4ea3.
[ForkJoinPool.commonPool-worker-11] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-11] 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:42511
[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 11638 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1125065444-48c571b_a1f437b9-d5e3-49d4-a3eb-daa0f4ef25f1/MANIFEST
has 186 artifact locations
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
- Removed dir
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1125065444-48c571b_a1f437b9-d5e3-49d4-a3eb-daa0f4ef25f1/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:40415
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:45477
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testCoderInferenceOfList
SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task
worker for ':' Thread 8,5,main]) completed. Took 50 mins 16.717 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> 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 55m 2s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/sugqqiejmrqks
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]
