See
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/375/display/redirect>
------------------------------------------
[...truncated 507.73 MB...]
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/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)
(13/16) (6737dee8f1b8f6b3453d145c18046e50).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (6/16).
[jobmanager-future-thread-8] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (1/16)
(ab4c7743a316f3caa8ecb9aa4ccd16db) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16) (2157ff940e0be34208bdf550fd330ef2) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(13/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)
(13/16) (6737dee8f1b8f6b3453d145c18046e50) [FINISHED]
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/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)
(3/16) (2157ff940e0be34208bdf550fd330ef2).
[jobmanager-future-thread-14] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-12] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (3/16)
(8ff401e9bd6c010aee28938c102911e4) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/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)
(3/16) (2157ff940e0be34208bdf550fd330ef2) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (1/16)
(ab4c7743a316f3caa8ecb9aa4ccd16db) switched from SCHEDULED 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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
86509a53bb2f1404357f19d1ffbda4e8.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (1/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@aed78bb) (3/16)
(8ff401e9bd6c010aee28938c102911e4) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (8/16)
(2b9071bc86efaf9531828238308c50fa) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (3/16) (attempt
#0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (8/16)
(2b9071bc86efaf9531828238308c50fa) [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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
b97c07ce08bdd4c2603f403cc597119e.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16) (attempt
#0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (6/16)
(8651a674f9cf29b384841d7998508b09) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (6/16)
(8651a674f9cf29b384841d7998508b09) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(6/16) (8651a674f9cf29b384841d7998508b09) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(8/16) (2b9071bc86efaf9531828238308c50fa) [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$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
c4492690caed8a74dde981684da5f3c7.
[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) (86509a53bb2f1404357f19d1ffbda4e8) switched from RUNNING to FINISHED.
[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)
(10/16) (b97c07ce08bdd4c2603f403cc597119e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(8/16) (2b9071bc86efaf9531828238308c50fa) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(6/16) (8651a674f9cf29b384841d7998508b09) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (8/16)
(2b9071bc86efaf9531828238308c50fa) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (6/16)
(8651a674f9cf29b384841d7998508b09) switched from DEPLOYING to RUNNING.
[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)
(2/16) (c4492690caed8a74dde981684da5f3c7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (4/16).
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (6/16)
(8651a674f9cf29b384841d7998508b09) 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@aed78bb) (8/16)
(2b9071bc86efaf9531828238308c50fa) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (4/16)
(96981ff1f2dd43064d198c6ca2bd8df5) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (4/16)
(96981ff1f2dd43064d198c6ca2bd8df5) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(4/16) (96981ff1f2dd43064d198c6ca2bd8df5) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(4/16) (96981ff1f2dd43064d198c6ca2bd8df5) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (4/16)
(96981ff1f2dd43064d198c6ca2bd8df5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (4/16)
(96981ff1f2dd43064d198c6ca2bd8df5) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (8/16)
(2b9071bc86efaf9531828238308c50fa) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (6/16)
(8651a674f9cf29b384841d7998508b09) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(8/16) (2b9071bc86efaf9531828238308c50fa).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(6/16) (8651a674f9cf29b384841d7998508b09).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (8/16)
(2b9071bc86efaf9531828238308c50fa) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (6/16)
(8651a674f9cf29b384841d7998508b09) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (4/16)
(96981ff1f2dd43064d198c6ca2bd8df5) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(4/16) (96981ff1f2dd43064d198c6ca2bd8df5).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (4/16)
(96981ff1f2dd43064d198c6ca2bd8df5) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (10/16)
(353e0b76e5693e14c9badbe33cc017ec) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (10/16)
(353e0b76e5693e14c9badbe33cc017ec) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (2/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 MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
c3806aef52224ce17c25b27604cc5bd5.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (2/16)
(581dd0c048122c4e9904a7288d3ac25f) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (2/16)
(581dd0c048122c4e9904a7288d3ac25f) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
c0762519de469feba27b389b62286d2b.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(2/16) (581dd0c048122c4e9904a7288d3ac25f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(10/16) (353e0b76e5693e14c9badbe33cc017ec) [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)
(14/16) (c3806aef52224ce17c25b27604cc5bd5) 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@aed78bb) (16/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)
(16/16) (c0762519de469feba27b389b62286d2b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(2/16) (581dd0c048122c4e9904a7288d3ac25f) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(10/16) (353e0b76e5693e14c9badbe33cc017ec) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (16/16)
(79384b7dd4825dd21589d72e92c9ee1d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem
stream leak safety net for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (16/16)
(79384b7dd4825dd21589d72e92c9ee1d) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(16/16) (79384b7dd4825dd21589d72e92c9ee1d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (2/16)
(581dd0c048122c4e9904a7288d3ac25f) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (10/16)
(353e0b76e5693e14c9badbe33cc017ec) 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@aed78bb) (2/16)
(581dd0c048122c4e9904a7288d3ac25f) 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@aed78bb) (10/16)
(353e0b76e5693e14c9badbe33cc017ec) 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@aed78bb) (14/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(16/16) (79384b7dd4825dd21589d72e92c9ee1d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (16/16)
(79384b7dd4825dd21589d72e92c9ee1d) 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@aed78bb) (16/16)
(79384b7dd4825dd21589d72e92c9ee1d) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
d7803f43616fc52ffbf9ee862c84067d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (14/16)
(b683fce9e3f770321f742890a79eb830) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (14/16)
(b683fce9e3f770321f742890a79eb830) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
5e31edc9b638f43c4f8afb1250797777.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(14/16) (b683fce9e3f770321f742890a79eb830) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
58e7d0734b9161637c8348030833fb04.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (11/16)
(d7803f43616fc52ffbf9ee862c84067d) 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)
4e6cf113259b989865bc376d1a39e448.
[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@aed78bb)
982036d06fc9d9a147859f9bfb8146fc.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(14/16) (b683fce9e3f770321f742890a79eb830) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (14/16)
(b683fce9e3f770321f742890a79eb830) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (2/16)
(581dd0c048122c4e9904a7288d3ac25f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (16/16)
(79384b7dd4825dd21589d72e92c9ee1d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (10/16)
(353e0b76e5693e14c9badbe33cc017ec) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (16/16)
(79384b7dd4825dd21589d72e92c9ee1d).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (10/16)
(353e0b76e5693e14c9badbe33cc017ec).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(9/16) (5e31edc9b638f43c4f8afb1250797777) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (16/16)
(79384b7dd4825dd21589d72e92c9ee1d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (10/16)
(353e0b76e5693e14c9badbe33cc017ec) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(2/16) (581dd0c048122c4e9904a7288d3ac25f).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (2/16)
(581dd0c048122c4e9904a7288d3ac25f) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(15/16) (58e7d0734b9161637c8348030833fb04) 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@aed78bb) (9/16).
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(1/16) (4e6cf113259b989865bc376d1a39e448) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (14/16)
(b683fce9e3f770321f742890a79eb830) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (14/16)
(b683fce9e3f770321f742890a79eb830).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (14/16)
(b683fce9e3f770321f742890a79eb830) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (5/16)
(982036d06fc9d9a147859f9bfb8146fc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (14/16)
(b683fce9e3f770321f742890a79eb830) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (9/16)
(dd0ba581b2c8223ea560550ca26a3295) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (9/16)
(dd0ba581b2c8223ea560550ca26a3295) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (15/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 MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
6737dee8f1b8f6b3453d145c18046e50.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (15/16)
(7c636c5fdfe281946fb33587ca4e829d) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (15/16)
(7c636c5fdfe281946fb33587ca4e829d) [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)
(13/16) (6737dee8f1b8f6b3453d145c18046e50) 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@aed78bb) (1/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(9/16) (dd0ba581b2c8223ea560550ca26a3295) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(15/16) (7c636c5fdfe281946fb33587ca4e829d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (1/16)
(ab4c7743a316f3caa8ecb9aa4ccd16db) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (1/16)
(ab4c7743a316f3caa8ecb9aa4ccd16db) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(1/16) (ab4c7743a316f3caa8ecb9aa4ccd16db) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (3/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(15/16) (7c636c5fdfe281946fb33587ca4e829d) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(9/16) (dd0ba581b2c8223ea560550ca26a3295) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(1/16) (ab4c7743a316f3caa8ecb9aa4ccd16db) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
2157ff940e0be34208bdf550fd330ef2.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (15/16)
(7c636c5fdfe281946fb33587ca4e829d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (1/16)
(ab4c7743a316f3caa8ecb9aa4ccd16db) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (15/16)
(7c636c5fdfe281946fb33587ca4e829d) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (3/16)
(8ff401e9bd6c010aee28938c102911e4) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (3/16)
(8ff401e9bd6c010aee28938c102911e4) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (9/16)
(dd0ba581b2c8223ea560550ca26a3295) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(3/16) (8ff401e9bd6c010aee28938c102911e4) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (1/16)
(ab4c7743a316f3caa8ecb9aa4ccd16db) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(3/16) (8ff401e9bd6c010aee28938c102911e4) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (3/16)
(8ff401e9bd6c010aee28938c102911e4) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition
(MapPartition at
PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0)
(3/16) (2157ff940e0be34208bdf550fd330ef2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
8651a674f9cf29b384841d7998508b09.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(13/16) (97ee682dbcbe5a515387c75a4c2c7840) [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@aed78bb)
2b9071bc86efaf9531828238308c50fa.
[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@aed78bb)
96981ff1f2dd43064d198c6ca2bd8df5.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (9/16)
(dd0ba581b2c8223ea560550ca26a3295) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at
network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(13/16) (97ee682dbcbe5a515387c75a4c2c7840) [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@aed78bb)
79384b7dd4825dd21589d72e92c9ee1d.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (3/16)
(8ff401e9bd6c010aee28938c102911e4) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (1/16)
(ab4c7743a316f3caa8ecb9aa4ccd16db) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (3/16)
(8ff401e9bd6c010aee28938c102911e4) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (9/16)
(dd0ba581b2c8223ea560550ca26a3295) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(3/16) (8ff401e9bd6c010aee28938c102911e4).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(9/16) (dd0ba581b2c8223ea560550ca26a3295).
[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@aed78bb)
353e0b76e5693e14c9badbe33cc017ec.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(1/16) (ab4c7743a316f3caa8ecb9aa4ccd16db).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (3/16)
(8ff401e9bd6c010aee28938c102911e4) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (6/16)
(8651a674f9cf29b384841d7998508b09) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (9/16)
(dd0ba581b2c8223ea560550ca26a3295) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (15/16)
(7c636c5fdfe281946fb33587ca4e829d) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task
resources for DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (15/16)
(7c636c5fdfe281946fb33587ca4e829d).
[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@aed78bb)
581dd0c048122c4e9904a7288d3ac25f.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (15/16)
(7c636c5fdfe281946fb33587ca4e829d) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
(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@aed78bb) (1/16)
(ab4c7743a316f3caa8ecb9aa4ccd16db) [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@aed78bb)
b683fce9e3f770321f742890a79eb830.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (8/16)
(2b9071bc86efaf9531828238308c50fa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
8ff401e9bd6c010aee28938c102911e4.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
97ee682dbcbe5a515387c75a4c2c7840.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
dd0ba581b2c8223ea560550ca26a3295.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (4/16)
(96981ff1f2dd43064d198c6ca2bd8df5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
7c636c5fdfe281946fb33587ca4e829d.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and
sending final execution state FINISHED to JobManager for task DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb)
ab4c7743a316f3caa8ecb9aa4ccd16db.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (16/16)
(79384b7dd4825dd21589d72e92c9ee1d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (10/16)
(353e0b76e5693e14c9badbe33cc017ec) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (2/16)
(581dd0c048122c4e9904a7288d3ac25f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (14/16)
(b683fce9e3f770321f742890a79eb830) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (3/16)
(8ff401e9bd6c010aee28938c102911e4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink
(org.apache.flink.api.java.io.DiscardingOutputFormat@aed78bb) (13/16)
(97ee682dbcbe5a515387c75a4c2c7840) 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@aed78bb) (9/16)
(dd0ba581b2c8223ea560550ca26a3295) 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@aed78bb) (15/16)
(7c636c5fdfe281946fb33587ca4e829d) 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@aed78bb) (1/16)
(ab4c7743a316f3caa8ecb9aa4ccd16db) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job
reifytimestampstest0invaluessucceeds-jenkins-1120185409-6741380
(a70d608ae2eac7b1ca118ec2ae407601) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job
a70d608ae2eac7b1ca118ec2ae407601 reached globally terminal state FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
reifytimestampstest0invaluessucceeds-jenkins-1120185409-6741380(a70d608ae2eac7b1ca118ec2ae407601).
[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.taskexecutor.TaskExecutor - Stopping TaskExecutor
akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher
akka://flink/user/dispatcherea2ff6d9-49cf-4bec-a5a8-fba8237c8e43.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all
currently running jobs of dispatcher
akka://flink/user/dispatcherea2ff6d9-49cf-4bec-a5a8-fba8237c8e43.
[flink-akka.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
d7c8df7325ea4fe42558259c9ca0396e: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting
down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job
a70d608ae2eac7b1ca118ec2ae407601 with leader id
9d633de381dcb320a8652e2cb89a4342 lost leadership.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the
SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending
the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed
spill file directory /tmp/flink-io-4bfb5567-8f16-491b-84fa-91e8527907a1
[flink-akka.actor.default-dispatcher-2] 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/dispatcherea2ff6d9-49cf-4bec-a5a8-fba8237c8e43.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader
service.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor
akka://flink/user/taskmanager_260.
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache
directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-9] INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:44297
[flink-akka.actor.default-dispatcher-2] 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 12820 msecs
[flink-runner-job-server] INFO
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
- Manifest at
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1120185409-6741380_c9954078-0ef0-4ea6-9691-ac68666f0cf2/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-1120185409-6741380_c9954078-0ef0-4ea6-9691-ac68666f0cf2/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
JobServer stopped on localhost:44081
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver -
ArtifactStagingServer stopped on localhost:38065
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
197 tests completed, 1 failed, 2 skipped
Finished generating test XML results (5.488 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunner>
Generating HTML test report...
Finished generating test html results (1.719 secs) into:
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner>
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker
for ':' Thread 4,5,main]) completed. Took 51 mins 49.483 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':beam-runners-flink_2.11-job-server:validatesPortableRunner'.
> There were failing tests. See the report at:
> file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunner/index.html>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 54m 36s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/loqg7bfbno4oi
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]
