See 
<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/161/display/redirect?page=changes>

Changes:

[github] Blog post for 2.8.0 release (#6852)

------------------------------------------
[...truncated 498.94 MB...]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (14/16) 
(d95d1c714e6f87442d862760ce711016) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (14/16) 
(d95d1c714e6f87442d862760ce711016).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (14/16) 
(d95d1c714e6f87442d862760ce711016) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
609b1dd24e9319662182e4f5643feea8.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
f720a7300a4e27c81b0238c11d502a64.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (5/16) 
(409bb4b89a244d19cdb3ec5b303d1dd9) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (5/16) 
(409bb4b89a244d19cdb3ec5b303d1dd9) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16) (409bb4b89a244d19cdb3ec5b303d1dd9) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(3/16) (609b1dd24e9319662182e4f5643feea8) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (5/16) 
(409bb4b89a244d19cdb3ec5b303d1dd9) [DEPLOYING].
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(15/16) (9d00c7930c9b32201f24d82328bdc8a9) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (5/16) 
(409bb4b89a244d19cdb3ec5b303d1dd9) switched from DEPLOYING to RUNNING.
    [MapPartition (MapPartition at 
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(15/16) (9d00c7930c9b32201f24d82328bdc8a9).
    [MapPartition (MapPartition at 
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(15/16) (9d00c7930c9b32201f24d82328bdc8a9) [FINISHED]
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(10/16) (f44512a32cc46e74155c4d6ccbeaa577) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(10/16) (f44512a32cc46e74155c4d6ccbeaa577).
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(10/16) (f44512a32cc46e74155c4d6ccbeaa577) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(1/16) (f720a7300a4e27c81b0238c11d502a64) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (1/16).
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16) (1b317c980df0bebd8713367eefa5a4a4) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16) (1b317c980df0bebd8713367eefa5a4a4).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (5/16) 
(409bb4b89a244d19cdb3ec5b303d1dd9) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16) (409bb4b89a244d19cdb3ec5b303d1dd9).
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (5/16) 
(409bb4b89a244d19cdb3ec5b303d1dd9) switched from DEPLOYING to RUNNING.
    [MapPartition (MapPartition at 
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16) (1b317c980df0bebd8713367eefa5a4a4) [FINISHED]
    [jobmanager-future-thread-14] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) switched from CREATED to SCHEDULED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (5/16) 
(409bb4b89a244d19cdb3ec5b303d1dd9) [FINISHED]
    [jobmanager-future-thread-14] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) switched from CREATED to SCHEDULED.
    [jobmanager-future-thread-14] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) switched from CREATED to SCHEDULED.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16) (attempt 
#0) to localhost
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) (attempt 
#0) to localhost
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
e60ffa26fa8c2846a37a02a4ecb454f9.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (16/16) (attempt 
#0) to localhost
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (1/16) 
(eea7a7b0f3a69ef5cc17f5fabc7aa4f8) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (1/16) 
(eea7a7b0f3a69ef5cc17f5fabc7aa4f8) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(1/16) (eea7a7b0f3a69ef5cc17f5fabc7aa4f8) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(4/16) (e60ffa26fa8c2846a37a02a4ecb454f9) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (4/16).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (1/16) 
(eea7a7b0f3a69ef5cc17f5fabc7aa4f8) [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@161f6dcd) 
fc4690be40e8af6a77b95aced55f1550.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (4/16) 
(ff2d38d5c3ba3ec878f4c8e797865340) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (4/16) 
(ff2d38d5c3ba3ec878f4c8e797865340) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (1/16) 
(eea7a7b0f3a69ef5cc17f5fabc7aa4f8) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(4/16) (ff2d38d5c3ba3ec878f4c8e797865340) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
480cef819e2e81747916b32acab19ea6.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (4/16) 
(ff2d38d5c3ba3ec878f4c8e797865340) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
19b0df743aefdb50ee9b066f122ce71b.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (8/16) 
(fc4690be40e8af6a77b95aced55f1550) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (4/16) 
(ff2d38d5c3ba3ec878f4c8e797865340) 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@161f6dcd) (1/16) 
(eea7a7b0f3a69ef5cc17f5fabc7aa4f8) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(7/16) (480cef819e2e81747916b32acab19ea6) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(6/16) (19b0df743aefdb50ee9b066f122ce71b) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (4/16) 
(ff2d38d5c3ba3ec878f4c8e797865340) 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@161f6dcd) (7/16).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (4/16) 
(ff2d38d5c3ba3ec878f4c8e797865340) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(4/16) (ff2d38d5c3ba3ec878f4c8e797865340).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (1/16) 
(eea7a7b0f3a69ef5cc17f5fabc7aa4f8) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(1/16) (eea7a7b0f3a69ef5cc17f5fabc7aa4f8).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (4/16) 
(ff2d38d5c3ba3ec878f4c8e797865340) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (1/16) 
(eea7a7b0f3a69ef5cc17f5fabc7aa4f8) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (7/16) 
(2ed43a8eb6d8b30f5bbfed5846822389) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (7/16) 
(2ed43a8eb6d8b30f5bbfed5846822389) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(7/16) (2ed43a8eb6d8b30f5bbfed5846822389) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (6/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 MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
8f63ddd4b8445b4f7d279ee2693c062e.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (6/16) 
(a8438f83d526450f7f3e32f51d735d7e) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem 
stream leak safety net for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (6/16) 
(a8438f83d526450f7f3e32f51d735d7e) [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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
cd59f9432c0c45adcfe1702df07c563a.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16) (a8438f83d526450f7f3e32f51d735d7e) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(11/16) (8f63ddd4b8445b4f7d279ee2693c062e) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (7/16) 
(2ed43a8eb6d8b30f5bbfed5846822389) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (6/16) 
(a8438f83d526450f7f3e32f51d735d7e) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (7/16) 
(2ed43a8eb6d8b30f5bbfed5846822389) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (6/16) 
(a8438f83d526450f7f3e32f51d735d7e) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(9/16) (cd59f9432c0c45adcfe1702df07c563a) 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@161f6dcd) (11/16).
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (6/16) 
(a8438f83d526450f7f3e32f51d735d7e) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (7/16) 
(2ed43a8eb6d8b30f5bbfed5846822389) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (11/16) 
(6e6dc0617b8c5bd72fd89e85b3bc0924) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (11/16) 
(6e6dc0617b8c5bd72fd89e85b3bc0924) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(11/16) (6e6dc0617b8c5bd72fd89e85b3bc0924) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (11/16) 
(6e6dc0617b8c5bd72fd89e85b3bc0924) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (9/16).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (11/16) 
(6e6dc0617b8c5bd72fd89e85b3bc0924) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (11/16) 
(6e6dc0617b8c5bd72fd89e85b3bc0924) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (7/16) 
(2ed43a8eb6d8b30f5bbfed5846822389) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(7/16) (2ed43a8eb6d8b30f5bbfed5846822389).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (6/16) 
(a8438f83d526450f7f3e32f51d735d7e) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (7/16) 
(2ed43a8eb6d8b30f5bbfed5846822389) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16) (a8438f83d526450f7f3e32f51d735d7e).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (6/16) 
(a8438f83d526450f7f3e32f51d735d7e) [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@161f6dcd) 
887eb79476571d6ccc1a4c8182e50704.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (9/16) 
(8d2af74a74fbe9d0a1d1c1b36397a6b9) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (9/16) 
(8d2af74a74fbe9d0a1d1c1b36397a6b9) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (11/16) 
(6e6dc0617b8c5bd72fd89e85b3bc0924) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(9/16) (8d2af74a74fbe9d0a1d1c1b36397a6b9) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (11/16) 
(6e6dc0617b8c5bd72fd89e85b3bc0924).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (11/16) 
(6e6dc0617b8c5bd72fd89e85b3bc0924) [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 MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
45d113f7fb8a221853609e6213fdf94c.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (9/16) 
(8d2af74a74fbe9d0a1d1c1b36397a6b9) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (9/16) 
(8d2af74a74fbe9d0a1d1c1b36397a6b9) 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@161f6dcd) (3/16) 
(887eb79476571d6ccc1a4c8182e50704) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (9/16) 
(8d2af74a74fbe9d0a1d1c1b36397a6b9) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(9/16) (8d2af74a74fbe9d0a1d1c1b36397a6b9).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (9/16) 
(8d2af74a74fbe9d0a1d1c1b36397a6b9) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(12/16) (45d113f7fb8a221853609e6213fdf94c) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (12/16).
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (9/16) 
(8d2af74a74fbe9d0a1d1c1b36397a6b9) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] 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@161f6dcd) 
d95d1c714e6f87442d862760ce711016.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (12/16) 
(7fc29368b07ff44744ab1773d68cbb7e) switched from CREATED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
9d00c7930c9b32201f24d82328bdc8a9.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (12/16) 
(7fc29368b07ff44744ab1773d68cbb7e) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
f44512a32cc46e74155c4d6ccbeaa577.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (14/16) 
(d95d1c714e6f87442d862760ce711016) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
1b317c980df0bebd8713367eefa5a4a4.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(12/16) (7fc29368b07ff44744ab1773d68cbb7e) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(15/16) (9d00c7930c9b32201f24d82328bdc8a9) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(10/16) (f44512a32cc46e74155c4d6ccbeaa577) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16).
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(16/16) (1b317c980df0bebd8713367eefa5a4a4) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (12/16) 
(7fc29368b07ff44744ab1773d68cbb7e) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (12/16) 
(7fc29368b07ff44744ab1773d68cbb7e) 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@161f6dcd) (12/16) 
(7fc29368b07ff44744ab1773d68cbb7e) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(15/16) (133f7cd40d3eba5838f3777f60bb38f1) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) 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@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] 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@161f6dcd) 
409bb4b89a244d19cdb3ec5b303d1dd9.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(10/16) (e8b246c69f85780617192a0f0f2cea13) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (5/16) 
(409bb4b89a244d19cdb3ec5b303d1dd9) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (12/16) 
(7fc29368b07ff44744ab1773d68cbb7e) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (12/16) 
(7fc29368b07ff44744ab1773d68cbb7e).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (12/16) 
(7fc29368b07ff44744ab1773d68cbb7e) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (16/16).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
ff2d38d5c3ba3ec878f4c8e797865340.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(16/16) (099c48300d08244681697c5a47a59bb8) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
eea7a7b0f3a69ef5cc17f5fabc7aa4f8.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
2ed43a8eb6d8b30f5bbfed5846822389.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (4/16) 
(ff2d38d5c3ba3ec878f4c8e797865340) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
a8438f83d526450f7f3e32f51d735d7e.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
6e6dc0617b8c5bd72fd89e85b3bc0924.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (1/16) 
(eea7a7b0f3a69ef5cc17f5fabc7aa4f8) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
8d2af74a74fbe9d0a1d1c1b36397a6b9.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (7/16) 
(2ed43a8eb6d8b30f5bbfed5846822389) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
7fc29368b07ff44744ab1773d68cbb7e.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
133f7cd40d3eba5838f3777f60bb38f1.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (6/16) 
(a8438f83d526450f7f3e32f51d735d7e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
e8b246c69f85780617192a0f0f2cea13.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (11/16) 
(6e6dc0617b8c5bd72fd89e85b3bc0924) 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@161f6dcd) (9/16) 
(8d2af74a74fbe9d0a1d1c1b36397a6b9) 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@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (12/16) 
(7fc29368b07ff44744ab1773d68cbb7e) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8).
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (15/16) 
(133f7cd40d3eba5838f3777f60bb38f1) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) 
(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@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] 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@161f6dcd) 
099c48300d08244681697c5a47a59bb8.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@161f6dcd) (10/16) 
(e8b246c69f85780617192a0f0f2cea13) 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@161f6dcd) (16/16) 
(099c48300d08244681697c5a47a59bb8) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 
reifytimestampstest0invaluessucceeds-jenkins-1030020149-f284610b 
(53ac69b53f0f56c6172806bb9d6cf369) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 
53ac69b53f0f56c6172806bb9d6cf369 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.taskexecutor.TaskExecutor - Stopping TaskExecutor 
akka://flink/user/taskmanager_242.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job 
reifytimestampstest0invaluessucceeds-jenkins-1030020149-f284610b(53ac69b53f0f56c6172806bb9d6cf369).
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher 
akka://flink/user/dispatcher8fb7e037-11fd-4a5a-8da0-4e8a91355495.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all 
currently running jobs of dispatcher 
akka://flink/user/dispatcher8fb7e037-11fd-4a5a-8da0-4e8a91355495.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting 
down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 
7fac83a515359c59989c1471c5c556f6: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the 
SlotManager.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending 
the SlotManager.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister 
TaskManager 45130b12dc35e1fa8cb01b2e4d344759 from the SlotManager.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 
53ac69b53f0f56c6172806bb9d6cf369 with leader id 
889d6d26ee46ed2716ca5f76979f4b38 lost leadership.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed 
spill file directory /tmp/flink-io-371cd720-9e29-4ecf-995e-b75aff6a76d6
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the 
network environment and its components.
    [flink-akka.actor.default-dispatcher-7] 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.taskexecutor.JobLeaderService - Stop job leader 
service.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor 
akka://flink/user/taskmanager_242.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher 
akka://flink/user/dispatcher8fb7e037-11fd-4a5a-8da0-4e8a91355495.
    [ForkJoinPool.commonPool-worker-11] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache 
directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-11] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:34427
    [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 12731 msecs
    [flink-runner-job-server] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - Manifest at 
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1030020149-f284610b_afcc4f6e-f68d-487f-98d6-3b89dd86cae1/MANIFEST
 has 185 artifact locations
    [flink-runner-job-server] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService
 - Removed dir 
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1030020149-f284610b_afcc4f6e-f68d-487f-98d6-3b89dd86cae1/
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - 
JobServer stopped on localhost:33053
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - 
ArtifactStagingServer stopped on localhost:38301

Gradle Test Executor 1 finished executing tests.

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunner

187 tests completed, 1 failed, 1 skipped
Finished generating test XML results (5.09 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 (2.17 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 3,5,main]) completed. Took 43 mins 0.284 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 45m 38s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date

Publishing build scan...
https://gradle.com/s/s5mf2v3tijjwa

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org

Reply via email to