See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/220/display/redirect>
------------------------------------------
[...truncated 396.73 MB...]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (13/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (16/16)
(6fc822c8e083237ee208ab6989d26d75).
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (51c1f297af5e9a832ec5f792e1a4b3f2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (8/16)
(672ce7bf5ef90bd331c403d22e85e4d2) switched from CREATED to DEPLOYING.
[jobmanager-future-thread-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (51c1f297af5e9a832ec5f792e1a4b3f2).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (1/16)
(0f134021f5653968ebbe7c813a8af5c1) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (1/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (16/16)
(6fc822c8e083237ee208ab6989d26d75) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (8/16)
(672ce7bf5ef90bd331c403d22e85e4d2) [DEPLOYING]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (2/16)
(f52fe7c1dd924306cda64275e5bb21a1) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(8/16) (672ce7bf5ef90bd331c403d22e85e4d2) [DEPLOYING].
[MapPartition (MapPartition at
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (51c1f297af5e9a832ec5f792e1a4b3f2) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (2/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16) (attempt
#0) to localhost
[jobmanager-future-thread-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) switched from CREATED to SCHEDULED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (8/16)
(672ce7bf5ef90bd331c403d22e85e4d2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (8/16)
(672ce7bf5ef90bd331c403d22e85e4d2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (8/16)
(672ce7bf5ef90bd331c403d22e85e4d2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (8/16)
(672ce7bf5ef90bd331c403d22e85e4d2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(8/16) (672ce7bf5ef90bd331c403d22e85e4d2).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (8/16)
(672ce7bf5ef90bd331c403d22e85e4d2) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (11/16)
(17c1f0a6426250a11afdba769cfd3422) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (11/16)
(17c1f0a6426250a11afdba769cfd3422) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(11/16) (17c1f0a6426250a11afdba769cfd3422) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (11/16)
(17c1f0a6426250a11afdba769cfd3422) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (11/16)
(17c1f0a6426250a11afdba769cfd3422) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (3/16).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (11/16)
(17c1f0a6426250a11afdba769cfd3422) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16) (193603cc476f85dd01320e0009212c4c) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16) (193603cc476f85dd01320e0009212c4c).
[jobmanager-future-thread-10] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task MapPartition (MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16) (193603cc476f85dd01320e0009212c4c) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (11/16)
(17c1f0a6426250a11afdba769cfd3422) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (11/16)
(17c1f0a6426250a11afdba769cfd3422).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (11/16)
(17c1f0a6426250a11afdba769cfd3422) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (3/16)
(cf2daf0aaeaea1d47d177a6835931fd6) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (3/16)
(cf2daf0aaeaea1d47d177a6835931fd6) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(3/16) (cf2daf0aaeaea1d47d177a6835931fd6) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16)
(4699a2a22fc73ba2e93b3d734dd0cf78) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (3/16)
(cf2daf0aaeaea1d47d177a6835931fd6) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16)
(4699a2a22fc73ba2e93b3d734dd0cf78) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(10/16) (4699a2a22fc73ba2e93b3d734dd0cf78) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (3/16)
(cf2daf0aaeaea1d47d177a6835931fd6) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (14/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (3/16)
(cf2daf0aaeaea1d47d177a6835931fd6) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16)
(4699a2a22fc73ba2e93b3d734dd0cf78) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16)
(4699a2a22fc73ba2e93b3d734dd0cf78) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16)
(4699a2a22fc73ba2e93b3d734dd0cf78) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16)
(4699a2a22fc73ba2e93b3d734dd0cf78) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (3/16)
(cf2daf0aaeaea1d47d177a6835931fd6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(3/16) (cf2daf0aaeaea1d47d177a6835931fd6).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16)
(4699a2a22fc73ba2e93b3d734dd0cf78).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (3/16)
(cf2daf0aaeaea1d47d177a6835931fd6) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all
FileSystem streams are closed for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16)
(4699a2a22fc73ba2e93b3d734dd0cf78) [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 MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
917feb7be76a5f384d28708234c3d3dd.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (14/16)
(3335ee791e648f940ca64393ba21c32d) 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 MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
fe3396962981c9e256ac39a7ba5a7d75.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (14/16)
(3335ee791e648f940ca64393ba21c32d) [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 MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
6c2aa95813799a3efc8156441a5babe3.
[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 MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
afdcd44997b8975bc8b40a5f514f5449.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(14/16) (3335ee791e648f940ca64393ba21c32d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(2/16) (917feb7be76a5f384d28708234c3d3dd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (fe3396962981c9e256ac39a7ba5a7d75) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16) (6c2aa95813799a3efc8156441a5babe3) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (14/16)
(3335ee791e648f940ca64393ba21c32d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (14/16)
(3335ee791e648f940ca64393ba21c32d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(6/16) (afdcd44997b8975bc8b40a5f514f5449) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (14/16)
(3335ee791e648f940ca64393ba21c32d) switched from DEPLOYING to RUNNING.
[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@3acc4ed9)
6fc822c8e083237ee208ab6989d26d75.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (13/16)
(ec303a5e54c5ece5c46e710d06987808) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (13/16)
(ec303a5e54c5ece5c46e710d06987808) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(13/16) (ec303a5e54c5ece5c46e710d06987808) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (16/16)
(6fc822c8e083237ee208ab6989d26d75) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (13/16)
(ec303a5e54c5ece5c46e710d06987808) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (13/16)
(ec303a5e54c5ece5c46e710d06987808) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (14/16)
(3335ee791e648f940ca64393ba21c32d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (14/16)
(3335ee791e648f940ca64393ba21c32d).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (1/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (13/16)
(ec303a5e54c5ece5c46e710d06987808) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (14/16)
(3335ee791e648f940ca64393ba21c32d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (13/16)
(ec303a5e54c5ece5c46e710d06987808) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (13/16)
(ec303a5e54c5ece5c46e710d06987808).
[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 MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
51c1f297af5e9a832ec5f792e1a4b3f2.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (13/16)
(ec303a5e54c5ece5c46e710d06987808) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (1/16)
(0f134021f5653968ebbe7c813a8af5c1) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (1/16)
(0f134021f5653968ebbe7c813a8af5c1) [DEPLOYING]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (51c1f297af5e9a832ec5f792e1a4b3f2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(1/16) (0f134021f5653968ebbe7c813a8af5c1) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (1/16)
(0f134021f5653968ebbe7c813a8af5c1) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (1/16)
(0f134021f5653968ebbe7c813a8af5c1) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (2/16)
(f52fe7c1dd924306cda64275e5bb21a1) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (2/16)
(f52fe7c1dd924306cda64275e5bb21a1) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(2/16) (f52fe7c1dd924306cda64275e5bb21a1) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (1/16)
(0f134021f5653968ebbe7c813a8af5c1) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (2/16)
(f52fe7c1dd924306cda64275e5bb21a1) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (2/16)
(f52fe7c1dd924306cda64275e5bb21a1) 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@3acc4ed9) (2/16)
(f52fe7c1dd924306cda64275e5bb21a1) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (1/16)
(0f134021f5653968ebbe7c813a8af5c1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(1/16) (0f134021f5653968ebbe7c813a8af5c1).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (1/16)
(0f134021f5653968ebbe7c813a8af5c1) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (2/16)
(f52fe7c1dd924306cda64275e5bb21a1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(2/16) (f52fe7c1dd924306cda64275e5bb21a1).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (2/16)
(f52fe7c1dd924306cda64275e5bb21a1) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(15/16) (0cd8b40b0aff14f287a1b920a0c9cf7a) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(6/16) (39b62b1fe9df8b1163f81c71ba21312b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16).
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) switched from DEPLOYING to RUNNING.
[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@3acc4ed9)
672ce7bf5ef90bd331c403d22e85e4d2.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(9/16) (2eda9142a96e0b139743da434e1d7a7c) [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 MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
193603cc476f85dd01320e0009212c4c.
[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@3acc4ed9)
17c1f0a6426250a11afdba769cfd3422.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (8/16)
(672ce7bf5ef90bd331c403d22e85e4d2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(6/16) (39b62b1fe9df8b1163f81c71ba21312b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(7/16) (193603cc476f85dd01320e0009212c4c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(9/16) (2eda9142a96e0b139743da434e1d7a7c).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (11/16)
(17c1f0a6426250a11afdba769cfd3422) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16).
[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@3acc4ed9)
cf2daf0aaeaea1d47d177a6835931fd6.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) [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@3acc4ed9)
4699a2a22fc73ba2e93b3d734dd0cf78.
[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@3acc4ed9)
3335ee791e648f940ca64393ba21c32d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(7/16) (f784dfbb3fd3237b53023d1bd6e2c83d) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (3/16)
(cf2daf0aaeaea1d47d177a6835931fd6) 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@3acc4ed9)
ec303a5e54c5ece5c46e710d06987808.
[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@3acc4ed9)
0f134021f5653968ebbe7c813a8af5c1.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (10/16)
(4699a2a22fc73ba2e93b3d734dd0cf78) 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@3acc4ed9)
f52fe7c1dd924306cda64275e5bb21a1.
[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@3acc4ed9)
0cd8b40b0aff14f287a1b920a0c9cf7a.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (14/16)
(3335ee791e648f940ca64393ba21c32d) 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@3acc4ed9)
39b62b1fe9df8b1163f81c71ba21312b.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (13/16)
(ec303a5e54c5ece5c46e710d06987808) 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@3acc4ed9)
2eda9142a96e0b139743da434e1d7a7c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (1/16)
(0f134021f5653968ebbe7c813a8af5c1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (2/16)
(f52fe7c1dd924306cda64275e5bb21a1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (15/16)
(0cd8b40b0aff14f287a1b920a0c9cf7a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (6/16)
(39b62b1fe9df8b1163f81c71ba21312b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (9/16)
(2eda9142a96e0b139743da434e1d7a7c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(7/16) (f784dfbb3fd3237b53023d1bd6e2c83d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9)
(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@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) [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@3acc4ed9)
f784dfbb3fd3237b53023d1bd6e2c83d.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@3acc4ed9) (7/16)
(f784dfbb3fd3237b53023d1bd6e2c83d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1105184749-261eb85f
(8ab36085980542e8fd6b76d372b1d9e5) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
8ab36085980542e8fd6b76d372b1d9e5 reached globally terminal state FINISHED.
[flink-runner-job-server] INFO
org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini
Cluster
[flink-runner-job-server] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest
endpoint.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcher81ac4b7b-2695-4cd1-9536-7b13877c60ba.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1105184749-261eb85f(8ab36085980542e8fd6b76d372b1d9e5).
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcher81ac4b7b-2695-4cd1-9536-7b13877c60ba.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_242.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister
TaskManager bfe58c0a7efb1832e7eadb843d5c30b0 from the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
ebfee640b442bf83116636e2aed3df2d: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.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-2] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
8ab36085980542e8fd6b76d372b1d9e5 with leader id
90593cddc9c3de3f39f3e1a6dff44377 lost leadership.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-5a2ef0e5-a511-4e60-b445-fccad07da546
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the
network environment and its components.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
- Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher
akka://flink/user/dispatcher81ac4b7b-2695-4cd1-9536-7b13877c60ba.
[ForkJoinPool.commonPool-worker-4] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_242.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-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:35443
[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 12193 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1105184749-261eb85f_7f3793cf-2a8e-4782-84c7-038b8f522e1e/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-1105184749-261eb85f_7f3793cf-2a8e-4782-84c7-038b8f522e1e/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:41723
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:37767
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.transforms.CombineTest$WindowingTests >
testFixedWindowsCombine SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker
for ':' Thread 10,5,main]) completed. Took 45 mins 13.881 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 48m 13s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/e3tj5gvqx66ws
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]
