You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/11/21 23:50:15 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #392
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/392/display/redirect?page=changes>
Changes:
[github] [BEAM-6058] Use vendored gRPC 1.13.1 dependency. (#7105)
------------------------------------------
[...truncated 515.60 MB...]
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (16/16) (3cd2702d45b0fd1de9c87e156378973a) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (7/16) (0e415aef02813a070a44d911fa5665d8) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (3/16) (f8fa9ddf66aa99b10f95f35bd25e652a) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-1] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (3/16) (f8fa9ddf66aa99b10f95f35bd25e652a) switched from DEPLOYING to RUNNING.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (14/16) (7b104bf390d88a9df98dcac603fe5919) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1) switched from CREATED to DEPLOYING.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (14/16) (7b104bf390d88a9df98dcac603fe5919).
[jobmanager-future-thread-16] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (7/16) (0e415aef02813a070a44d911fa5665d8) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1) [DEPLOYING].
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (14/16) (7b104bf390d88a9df98dcac603fe5919) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (7/16) (0e415aef02813a070a44d911fa5665d8).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (7/16) (0e415aef02813a070a44d911fa5665d8) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (3/16) (f8fa9ddf66aa99b10f95f35bd25e652a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) switched from SCHEDULED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (3/16) (f8fa9ddf66aa99b10f95f35bd25e652a).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16) (attempt #0) to localhost
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (3/16) (f8fa9ddf66aa99b10f95f35bd25e652a) [FINISHED]
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (15/16) (9038525fd74ec7a935ba01d1b54f477e) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (15/16) (9038525fd74ec7a935ba01d1b54f477e).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1) [DEPLOYING].
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (15/16) (9038525fd74ec7a935ba01d1b54f477e) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1) [FINISHED]
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (9075ed8fbad67839ccf376ed55f64629) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (9075ed8fbad67839ccf376ed55f64629).
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (13/16) (740da1fd67ce977b6c41efa47dca383c) 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 - Freeing task resources for MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (13/16) (740da1fd67ce977b6c41efa47dca383c).
[MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (9075ed8fbad67839ccf376ed55f64629) [FINISHED]
[jobmanager-future-thread-14] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) switched from CREATED to SCHEDULED.
[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) (740da1fd67ce977b6c41efa47dca383c) [FINISHED]
[jobmanager-future-thread-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (attempt #0) to localhost
[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@20cde912) d76ed53c503add601d77a8f25bfa5c9d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc) switched from CREATED to DEPLOYING.
[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 MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) bc2d717f59dc4566f2aac14bf0afb77d.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc) [DEPLOYING]
[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 MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 1431b40213a6bb265f65e8b30af8d51f.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (2/16) (d76ed53c503add601d77a8f25bfa5c9d) 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@20cde912) 1b51b0b2f87bfe615725e5ff9d3b5573.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc) [DEPLOYING].
[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) (11/16) (bc2d717f59dc4566f2aac14bf0afb77d) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (12/16) (1431b40213a6bb265f65e8b30af8d51f) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (5/16) (1b51b0b2f87bfe615725e5ff9d3b5573) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc) 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@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) d34f9f61fdd4a067c254995ef3a12215.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5) [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) (10/16) (d34f9f61fdd4a067c254995ef3a12215) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) 8ef04c66ed359e517592176250a77730.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 3cd2702d45b0fd1de9c87e156378973a.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 7b104bf390d88a9df98dcac603fe5919.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) 0e415aef02813a070a44d911fa5665d8.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (6/16) (8ef04c66ed359e517592176250a77730) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5).
[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) (16/16) (3cd2702d45b0fd1de9c87e156378973a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12) [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) (14/16) (7b104bf390d88a9df98dcac603fe5919) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) [DEPLOYING]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (7/16) (0e415aef02813a070a44d911fa5665d8) 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@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) 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@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) f8fa9ddf66aa99b10f95f35bd25e652a.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 9038525fd74ec7a935ba01d1b54f477e.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) 3443b13ec225dda84bc699204d5289b1.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (3/16) (f8fa9ddf66aa99b10f95f35bd25e652a) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 9075ed8fbad67839ccf376ed55f64629.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) [DEPLOYING].
[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) (15/16) (9038525fd74ec7a935ba01d1b54f477e) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) 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@20cde912) (1/16) (3443b13ec225dda84bc699204d5289b1) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) (9/16) (9075ed8fbad67839ccf376ed55f64629) 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@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at PAssert$155/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 740da1fd67ce977b6c41efa47dca383c.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) [DEPLOYING]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) 853750e1fec33738f142da5e7b8f38fc.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) 0de4acd572df03bf1185cb0eb67b6e86.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) d8e4936937cb6e1e00600b2dd38113f5.
[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) (13/16) (740da1fd67ce977b6c41efa47dca383c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) fe8bf8f5ab529e6ff675d0c01285af12.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) 58f087f3bbf0fa38b3547f5e1f787829.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) 18831cbc870a7e8dcade5d31c80d2680.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (4/16) (853750e1fec33738f142da5e7b8f38fc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) 5de78b3e5ce64fe9cfdb79e7790dc45b.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (12/16) (0de4acd572df03bf1185cb0eb67b6e86) 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@20cde912) (11/16) (d8e4936937cb6e1e00600b2dd38113f5) 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@20cde912) (10/16) (fe8bf8f5ab529e6ff675d0c01285af12) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (19e27491f2ba4360728d686419f46597).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (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@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) bfcfc57839746a93860e9567c87d53e7.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) 19e27491f2ba4360728d686419f46597.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@20cde912) (15/16) (58f087f3bbf0fa38b3547f5e1f787829) 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@20cde912) (16/16) (18831cbc870a7e8dcade5d31c80d2680) 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@20cde912) (14/16) (5de78b3e5ce64fe9cfdb79e7790dc45b) 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@20cde912) (9/16) (bfcfc57839746a93860e9567c87d53e7) 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@20cde912) (13/16) (19e27491f2ba4360728d686419f46597) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1121234939-2805e4d5 (7d0b7b37d9599caef49714ca0893e3e7) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 7d0b7b37d9599caef49714ca0893e3e7 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-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1121234939-2805e4d5(7d0b7b37d9599caef49714ca0893e3e7).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatchere5fee937-e5f9-449c-8d8d-ab3311b71f41.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatchere5fee937-e5f9-449c-8d8d-ab3311b71f41.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 0530c59ec8156f09238496550d865624: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[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.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 7d0b7b37d9599caef49714ca0893e3e7 with leader id 993cf1d2e1e54bef4aad9ad9990a4b64 lost leadership.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-91fd00c0-8f51-4681-85b5-aa1e7f0b116b
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-11] 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.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatchere5fee937-e5f9-449c-8d8d-ab3311b71f41.
[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:46847
[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 10754 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1121234939-2805e4d5_fb0ec110-3b82-4b0c-8a6a-27452971ad8a/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-1121234939-2805e4d5_fb0ec110-3b82-4b0c-8a6a-27452971ad8a/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:33129
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:42255
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 (1.642 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.863 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 10,5,main]) completed. Took 46 mins 44.155 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 49m 9s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/icjo5qhzxipvc
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink #393
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/393/display/redirect>
------------------------------------------
[...truncated 204.48 MB...]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (3/16) (063f8d055be5e11a1c6d598fe2ffec85) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at PAssert$91/WindowToken/Window.Assign.out/beam:env:docker:v1:0) (7/16) (02586673d26bf626d7b3a33677276162) 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@49f125d7) (3/16) (063f8d055be5e11a1c6d598fe2ffec85) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (3/16) (063f8d055be5e11a1c6d598fe2ffec85) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (3/16) (063f8d055be5e11a1c6d598fe2ffec85).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (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@49f125d7) (3/16) (063f8d055be5e11a1c6d598fe2ffec85) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (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@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb) [DEPLOYING]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb) 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@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (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@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (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@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (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@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (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@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (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@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (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@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3) 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@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (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@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2) 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@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715) [DEPLOYING]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b) 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@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (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@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa) 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@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2) [DEPLOYING].
[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@516a6352) f5cce1175cad2e1f78cae57ba64f6eeb.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2) 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@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (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@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (15/16) (f5cce1175cad2e1f78cae57ba64f6eeb) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (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@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (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@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc) [FINISHED]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (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@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16).
[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@49f125d7) ec231829cb8fac04c4080e7dcb2a7c7a.
[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@49f125d7) b89b6082749d69ab9d083efb21749883.
[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@49f125d7) 063f8d055be5e11a1c6d598fe2ffec85.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (2/16) (ec231829cb8fac04c4080e7dcb2a7c7a) 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@2ea37e01) 5840dcb5826871442686e749bf7f0fbb.
[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@516a6352) c858ca142c034b5300ec7005754701f7.
[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@49f125d7) c819a1000bfa161389cb006eff139848.
[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@49f125d7) 4f50275faf31b623ca9c598af5f2506b.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (12/16) (b89b6082749d69ab9d083efb21749883) 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@49f125d7) f056beefb912f699a3b58641e8d52bc6.
[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@2ea37e01) d98252335849a1201bd5b33d1ab864e3.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (3/16) (063f8d055be5e11a1c6d598fe2ffec85) 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@2ea37e01) f79e7492931707b4168c050c1df35bb2.
[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@2ea37e01) aec6de1c3cf3a38a2695fa3a4dec52f2.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (8/16) (5840dcb5826871442686e749bf7f0fbb) 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@2ea37e01) f97e31be4621d4da16fce3c854043715.
[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@2ea37e01) f1836a774dd58b4c72863ede05e2e87b.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (14/16) (c858ca142c034b5300ec7005754701f7) 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@516a6352) 1cc12bb5eb9ed9ba856d2adfb8a073b2.
[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@49f125d7) 0185a00ca0c2028f122932786b09d0bc.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (11/16) (c819a1000bfa161389cb006eff139848) 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@2ea37e01) 37a0521285d372ab54d50175bb3ca6fa.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (10/16) (4f50275faf31b623ca9c598af5f2506b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (13/16) (f056beefb912f699a3b58641e8d52bc6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (7/16) (d98252335849a1201bd5b33d1ab864e3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (13/16) (f79e7492931707b4168c050c1df35bb2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (14/16) (aec6de1c3cf3a38a2695fa3a4dec52f2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (10/16) (f97e31be4621d4da16fce3c854043715) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@2ea37e01) (1/16) (f1836a774dd58b4c72863ede05e2e87b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (2/16) (1cc12bb5eb9ed9ba856d2adfb8a073b2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@49f125d7) (15/16) (0185a00ca0c2028f122932786b09d0bc) 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@2ea37e01) (11/16) (37a0521285d372ab54d50175bb3ca6fa) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6) switched from CREATED to DEPLOYING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (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@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6) [DEPLOYING]
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6) [DEPLOYING].
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6) 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@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6) switched from DEPLOYING to RUNNING.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6) switched from RUNNING to FINISHED.
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6).
[DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (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@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6) [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@516a6352) 47d162f1b3d72edb2c0009dab541d2f6.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@516a6352) (7/16) (47d162f1b3d72edb2c0009dab541d2f6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job countingsourcetest0testboundedsourcesplits-jenkins-1122002415-8bedcde9 (2ad2d3c553cdd9700214095979c53644) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 2ad2d3c553cdd9700214095979c53644 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.jobmaster.JobMaster - Stopping the JobMaster for job countingsourcetest0testboundedsourcesplits-jenkins-1122002415-8bedcde9(2ad2d3c553cdd9700214095979c53644).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher513674c3-4fb3-466f-a46e-7df89f31cf8f.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher513674c3-4fb3-466f-a46e-7df89f31cf8f.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 7e6f3a6193185fcec43d95a6a6852ee1: JobManager is shutting down..
[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.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-7] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 2ad2d3c553cdd9700214095979c53644 with leader id 8af2aa2aa2b99d8662a1e2205c2a40d0 lost leadership.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-c5fa05f7-a1a7-481f-9336-4b7bceee3529
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher513674c3-4fb3-466f-a46e-7df89f31cf8f.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:39395
[flink-akka.actor.default-dispatcher-6] 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 14039 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1122002415-8bedcde9_d8c1917f-6a43-415e-8a66-5507268ee331/MANIFEST has 186 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1122002415-8bedcde9_d8c1917f-6a43-415e-8a66-5507268ee331/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:35341
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:35437
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner
org.apache.beam.sdk.PipelineTest > testTupleProjectionTransform SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunner (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 19 mins 24.521 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 1' finished with non-zero exit value 1
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 23m 25s
75 actionable tasks: 69 executed, 5 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/vx6wosxkmlo6w
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscribe@beam.apache.org
For additional commands, e-mail: builds-help@beam.apache.org