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

Changes:

[scott] Replace precommit dashboard image with an actual image

------------------------------------------
[...truncated 501.14 MB...]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (15/16) 
(26d166d21d153fdd97e40e5723445247) switched from CREATED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (3/16) 
(5c575788a8a2b3028d6fcb4c72be8313) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (5/16) 
(94e536647e9285562630adc766181f10) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (15/16) 
(26d166d21d153fdd97e40e5723445247) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(15/16) (26d166d21d153fdd97e40e5723445247) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (4/16) 
(85141ff9730d9d3bfc91ce28e4a7b9ab) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (15/16) 
(26d166d21d153fdd97e40e5723445247) [DEPLOYING].
    [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) 
(15/16) (11c6b7b604903b869f6ade34c721db9e) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (15/16) 
(26d166d21d153fdd97e40e5723445247) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (5/16) 
(94e536647e9285562630adc766181f10) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(5/16) (94e536647e9285562630adc766181f10).
    [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) 
(11/16) (b585dbc274345be8809aeca8b8d63695) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (5/16) 
(94e536647e9285562630adc766181f10) [FINISHED]
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (11/16).
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (9/16) 
(e2c6f276a08e9ab1d51a89a8ea312f64) 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@3bb02a5f) (14/16) 
(520f3e01ea7e51b1c0373d7426921ddc) 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@3bb02a5f) (7/16) 
(30da2bdf9bb0951f948e8596a1c2671f) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (15/16) 
(26d166d21d153fdd97e40e5723445247) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (15/16) 
(26d166d21d153fdd97e40e5723445247).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (15/16) 
(26d166d21d153fdd97e40e5723445247) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (9/16) 
(e2c6f276a08e9ab1d51a89a8ea312f64) 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 DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
94e536647e9285562630adc766181f10.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (7/16) 
(30da2bdf9bb0951f948e8596a1c2671f) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (11/16) 
(c1866ea5b6c1ca117df554904c9b10d7) 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 DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
26d166d21d153fdd97e40e5723445247.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (11/16) 
(c1866ea5b6c1ca117df554904c9b10d7) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(11/16) (c1866ea5b6c1ca117df554904c9b10d7) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (14/16) 
(520f3e01ea7e51b1c0373d7426921ddc) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (11/16) 
(c1866ea5b6c1ca117df554904c9b10d7) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (5/16) 
(94e536647e9285562630adc766181f10) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (11/16) 
(c1866ea5b6c1ca117df554904c9b10d7) 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@3bb02a5f) (15/16) 
(26d166d21d153fdd97e40e5723445247) 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@3bb02a5f) (5/16) 
(94e536647e9285562630adc766181f10) 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@3bb02a5f) (15/16) 
(26d166d21d153fdd97e40e5723445247) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (11/16) 
(c1866ea5b6c1ca117df554904c9b10d7) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (11/16) 
(c1866ea5b6c1ca117df554904c9b10d7).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (11/16) 
(c1866ea5b6c1ca117df554904c9b10d7) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (11/16) 
(c1866ea5b6c1ca117df554904c9b10d7) 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@3bb02a5f) 
c1866ea5b6c1ca117df554904c9b10d7.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (11/16) 
(c1866ea5b6c1ca117df554904c9b10d7) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(2/16) (ea71c7f0096c408a9b44a55b8aa0df85) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(2/16) (ea71c7f0096c408a9b44a55b8aa0df85).
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(2/16) (ea71c7f0096c408a9b44a55b8aa0df85) [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) 
ea71c7f0096c408a9b44a55b8aa0df85.
    [jobmanager-future-thread-16] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) switched from CREATED to SCHEDULED.
    [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) (9b65c0abfc3dcc6d14245fed0e0a9219) 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) (9b65c0abfc3dcc6d14245fed0e0a9219).
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (2/16) (attempt 
#0) to localhost
    [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) (9b65c0abfc3dcc6d14245fed0e0a9219) [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) 
9b65c0abfc3dcc6d14245fed0e0a9219.
    [jobmanager-future-thread-3] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) switched from CREATED to SCHEDULED.
    [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) 
(2/16) (ea71c7f0096c408a9b44a55b8aa0df85) 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@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) 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@3bb02a5f) (10/16) (attempt 
#0) to localhost
    [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) 
(10/16) (9b65c0abfc3dcc6d14245fed0e0a9219) 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@3bb02a5f) (2/16).
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(6/16) (32bbf7a069372532b737c2f3072073a4) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(6/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) 
(6/16) (32bbf7a069372532b737c2f3072073a4).
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(6/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) 
(6/16) (32bbf7a069372532b737c2f3072073a4) [FINISHED]
    [jobmanager-future-thread-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) switched from CREATED to SCHEDULED.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(13/16) (3354eeac9aa1f8ec70f53398ca6c64c8) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at 
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(13/16) (3354eeac9aa1f8ec70f53398ca6c64c8).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) switched from CREATED to DEPLOYING.
    [MapPartition (MapPartition at 
PAssert$148/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$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(13/16) (3354eeac9aa1f8ec70f53398ca6c64c8) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) switched from SCHEDULED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(2/16) (be48cb87570345acc91c7fce86dc1a95) [DEPLOYING].
    [jobmanager-future-thread-5] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) switched from CREATED to SCHEDULED.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (6/16) (attempt 
#0) to localhost
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (13/16) (attempt 
#0) to localhost
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) 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@3bb02a5f) (10/16).
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) switched from DEPLOYING to RUNNING.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(12/16) (9cbafed341137cfe6fd9fbb1b91684c5) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(12/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) 
(12/16) (9cbafed341137cfe6fd9fbb1b91684c5).
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(12/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) 
(12/16) (9cbafed341137cfe6fd9fbb1b91684c5) [FINISHED]
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition 
(MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(1/16) (bc24ef58f45635a15decb27ae6752a92) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(1/16) (bc24ef58f45635a15decb27ae6752a92).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(2/16) (be48cb87570345acc91c7fce86dc1a95).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) [FINISHED]
    [jobmanager-future-thread-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) switched from CREATED to SCHEDULED.
    [MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all 
FileSystem streams are closed for task MapPartition (MapPartition at 
PAssert$148/GroupGlobally/GroupDummyAndContents.out/beam:env:docker:v1:0) 
(1/16) (bc24ef58f45635a15decb27ae6752a92) [FINISHED]
    [jobmanager-future-thread-13] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) switched from CREATED to SCHEDULED.
    [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) 
32bbf7a069372532b737c2f3072073a4.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) 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@3bb02a5f) (12/16) (attempt 
#0) to localhost
    [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) 
3354eeac9aa1f8ec70f53398ca6c64c8.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (1/16) (attempt 
#0) to localhost
    [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) (32bbf7a069372532b737c2f3072073a4) 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@3bb02a5f) (6/16).
    [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) 
(13/16) (3354eeac9aa1f8ec70f53398ca6c64c8) 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@3bb02a5f) (13/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) (e3e427d0fd9ab970880d5d7e93a6ff11) 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) (e3e427d0fd9ab970880d5d7e93a6ff11).
    [jobmanager-future-thread-16] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) switched from CREATED to SCHEDULED.
    [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) (e3e427d0fd9ab970880d5d7e93a6ff11) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(6/16) (996b3b08c34fa091552a21f64a837a68) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) switched from SCHEDULED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(10/16) (5178236385028cac687d547d736bfd17) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (16/16) (attempt 
#0) to localhost
    [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) 
9cbafed341137cfe6fd9fbb1b91684c5.
    [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@3bb02a5f) 
be48cb87570345acc91c7fce86dc1a95.
    [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) 
bc24ef58f45635a15decb27ae6752a92.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) [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) 
(12/16) (9cbafed341137cfe6fd9fbb1b91684c5) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) 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@3bb02a5f) (2/16) 
(be48cb87570345acc91c7fce86dc1a95) 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) 
(1/16) (bc24ef58f45635a15decb27ae6752a92) 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@3bb02a5f) (12/16).
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) 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@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(13/16) (702f6b6c882b157b425235014e35afc3) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(6/16) (996b3b08c34fa091552a21f64a837a68).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(12/16) (cf63e0c9b0d5461e3d90b47a8cb61a96) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) 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@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) 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@3bb02a5f) (1/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) 
e3e427d0fd9ab970880d5d7e93a6ff11.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) [DEPLOYING]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(1/16) (99b1525a46366f04324e4a5a17e08d59) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) [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) 
(16/16) (e3e427d0fd9ab970880d5d7e93a6ff11) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) [DEPLOYING].
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) 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@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) 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@3bb02a5f) (16/16).
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources 
for DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(1/16) (99b1525a46366f04324e4a5a17e08d59).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96).
    [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@3bb02a5f) 
5178236385028cac687d547d736bfd17.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) [FINISHED]
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) switched from CREATED to DEPLOYING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (10/16) 
(5178236385028cac687d547d736bfd17) 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@3bb02a5f) 
996b3b08c34fa091552a21f64a837a68.
    [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@3bb02a5f) 
702f6b6c882b157b425235014e35afc3.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for 
task DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(16/16) (bd070043caaeaea07c0dfa44514ceb62) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (6/16) 
(996b3b08c34fa091552a21f64a837a68) 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@3bb02a5f) 
99b1525a46366f04324e4a5a17e08d59.
    [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@3bb02a5f) 
cf63e0c9b0d5461e3d90b47a8cb61a96.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (13/16) 
(702f6b6c882b157b425235014e35afc3) 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@3bb02a5f) (1/16) 
(99b1525a46366f04324e4a5a17e08d59) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at 
network: DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (12/16) 
(cf63e0c9b0d5461e3d90b47a8cb61a96) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) 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@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) switched from DEPLOYING to RUNNING.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) switched from RUNNING to FINISHED.
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task 
resources for DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62).
    [DataSink (org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
(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@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and 
sending final execution state FINISHED to JobManager for task DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) 
bd070043caaeaea07c0dfa44514ceb62.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink 
(org.apache.flink.api.java.io.DiscardingOutputFormat@3bb02a5f) (16/16) 
(bd070043caaeaea07c0dfa44514ceb62) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 
reifytimestampstest0invaluessucceeds-jenkins-1026211111-90548614 
(d74028a58370641385f51a0a541baee0) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 
d74028a58370641385f51a0a541baee0 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-6] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher 
akka://flink/user/dispatchera8342a99-2160-4462-98c9-94376871c6fa.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job 
reifytimestampstest0invaluessucceeds-jenkins-1026211111-90548614(d74028a58370641385f51a0a541baee0).
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all 
currently running jobs of dispatcher 
akka://flink/user/dispatchera8342a99-2160-4462-98c9-94376871c6fa.
    [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-4] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the 
SlotManager.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting 
down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending 
the SlotManager.
    [flink-akka.actor.default-dispatcher-4] INFO 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister 
TaskManager 2de7cebaf6bd3fb4734b34eb926edba5 from the SlotManager.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 
8c78eb23afe2f5f177543fc0b8c201e0: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-6] INFO 
org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 
d74028a58370641385f51a0a541baee0 with leader id 
a5fe202b02608ca3eb91373e887c48bf lost leadership.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator
 - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-7] INFO 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher 
akka://flink/user/dispatchera8342a99-2160-4462-98c9-94376871c6fa.
    [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-c2ef96fc-3236-417a-a0f4-a9d98478d76f
    [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-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.
    [ForkJoinPool.commonPool-worker-13] INFO 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache 
directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-13] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:40187
    [flink-akka.actor.default-dispatcher-2] INFO 
org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
    [flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - 
Execution finished in 11458 msecs
    [flink-runner-job-server] INFO 
org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService
 - Manifest at 
/tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1026211111-90548614_46bbd13b-1345-4cfe-b0fd-cf59c548963f/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-1026211111-90548614_46bbd13b-1345-4cfe-b0fd-cf59c548963f/
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - 
JobServer stopped on localhost:39291
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - 
ArtifactStagingServer stopped on localhost:46499

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 (3.326 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.756 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 42 mins 19.247 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 44m 52s
76 actionable tasks: 71 executed, 4 from cache, 1 up-to-date

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

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

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to