You are viewing a plain text version of this content. The canonical link for it is here.
Posted to builds@beam.apache.org by Apache Jenkins Server <je...@builds.apache.org> on 2018/12/13 22:05:46 UTC

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #175

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

Changes:

[relax] Stop subclassing user pojos.

[relax] spotless.

------------------------------------------
[...truncated 270.68 MB...]
    [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 2b211af4c4d76e9871452788e51d49ff.
    [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 57b61d03910aafff8113f9d804d2b981.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (9/16) (357e125cf63cebc4413b82b8e3ef0d5c) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (4/16) (9d9542eb816a09fa117c5db25c7f526e) [DEPLOYING].
    [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 104bb7988e2c48ecbd7beb1e771f2f13.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (9d9542eb816a09fa117c5db25c7f526e) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (16/16) (ff54a1cbd6e1873f66c0e1b092dc3670) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (9d9542eb816a09fa117c5db25c7f526e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (11/16) (b171387c321702df406a4165c10d832e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (7/16).
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16) (2b211af4c4d76e9871452788e51d49ff) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (4/16) (9d9542eb816a09fa117c5db25c7f526e).
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (4/16) (9d9542eb816a09fa117c5db25c7f526e) [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 1d7a1039b7ce56f949e20abf152924ba.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16) (57b61d03910aafff8113f9d804d2b981) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b) [DEPLOYING]
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16) (104bb7988e2c48ecbd7beb1e771f2f13) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b) [DEPLOYING].
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (9d9542eb816a09fa117c5db25c7f526e) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (10/16) (1d7a1039b7ce56f949e20abf152924ba) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b).
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (9/16).
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136) [DEPLOYING]
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (16/16).
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136) [DEPLOYING].
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3) [DEPLOYING]
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3) [DEPLOYING].
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136).
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (11/16).
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3) [DEPLOYING].
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3).
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3) [FINISHED]
    [DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8) [DEPLOYING]
    [DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8) [DEPLOYING].
    [DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8) [DEPLOYING].
    [DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (2/16).
    [DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8).
    [DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8) [FINISHED]
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427) [DEPLOYING]
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427) [DEPLOYING].
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427) [DEPLOYING].
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (14/16).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427).
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427) [FINISHED]
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb) [DEPLOYING]
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb) [DEPLOYING].
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb) [DEPLOYING].
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (10/16).
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb).
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb) [FINISHED]
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40) [DEPLOYING]
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (15/16).
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40) [DEPLOYING].
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f) [DEPLOYING].
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (13/16).
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40).
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40) [FINISHED]
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f) [DEPLOYING].
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f) switched from DEPLOYING to RUNNING.
    [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 31559285b3e80982d746a31d67dbdc72.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f).
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f) [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) da36c728b485981dce89f416df7a737f.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243) [DEPLOYING]
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (6/16) (31559285b3e80982d746a31d67dbdc72) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (3/16) (da36c728b485981dce89f416df7a737f) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (6/16).
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 7298aff8f5a82e54d9e36793b2129b2b.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243).
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243) [FINISHED]
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501) [DEPLOYING]
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501) [DEPLOYING].
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501) [DEPLOYING].
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (7298aff8f5a82e54d9e36793b2129b2b) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501).
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (3/16).
    [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 (DiscardingOutput) a1a77682b8890e76dfff0f027df0e6e6.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63) [DEPLOYING]
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63) [DEPLOYING].
    [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 (DiscardingOutput) 1d8ef74bfc0055719fe53ec4ace1e2f8.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (a1a77682b8890e76dfff0f027df0e6e6) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63) switched from DEPLOYING to RUNNING.
    [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 (DiscardingOutput) 9d9542eb816a09fa117c5db25c7f526e.
    [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 (DiscardingOutput) ce689b0b6d4bcd39658f32ebf2392c8b.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63).
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63) [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 (DiscardingOutput) dcb45b0038242019a6b83595fd992136.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (1d8ef74bfc0055719fe53ec4ace1e2f8) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63) switched from DEPLOYING to RUNNING.
    [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 (DiscardingOutput) ddff2867f9e30f4d0c2dcac67ce347d3.
    [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 (DiscardingOutput) 01a19a8469f54757693d7728f6a3b6c8.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (9d9542eb816a09fa117c5db25c7f526e) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) c072400fcae4a9d04ba7da9149c53427.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (ce689b0b6d4bcd39658f32ebf2392c8b) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) cbe702ad4dddd6c3ad7cfa2d84c66cdb.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (dcb45b0038242019a6b83595fd992136) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) a1e840cab1a8b2d9c8b4c159e5a29b40.
    [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 (DiscardingOutput) 73628088c2f3e9e593e84eb1d2bfba5f.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (ddff2867f9e30f4d0c2dcac67ce347d3) 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 (DiscardingOutput) a29c83d112ecc34b9d2ea38e6d221243.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (01a19a8469f54757693d7728f6a3b6c8) 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 (DiscardingOutput) ef2666acaffd85c19e5ab45d85f0c501.
    [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 (DiscardingOutput) fd04eacea44e480f575447c149371b63.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (c072400fcae4a9d04ba7da9149c53427) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (cbe702ad4dddd6c3ad7cfa2d84c66cdb) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (a1e840cab1a8b2d9c8b4c159e5a29b40) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (73628088c2f3e9e593e84eb1d2bfba5f) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (a29c83d112ecc34b9d2ea38e6d221243) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (ef2666acaffd85c19e5ab45d85f0c501) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (fd04eacea44e480f575447c149371b63) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (e7542db5d6317fda3926d02b2bc186f8) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (e7542db5d6317fda3926d02b2bc186f8).
    [MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (e7542db5d6317fda3926d02b2bc186f8) [FINISHED]
    [jobmanager-future-thread-14] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) switched from CREATED to SCHEDULED.
    [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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) e7542db5d6317fda3926d02b2bc186f8.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (8/16) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (e7542db5d6317fda3926d02b2bc186f8) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (8/16).
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) [DEPLOYING]
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) [DEPLOYING].
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) [DEPLOYING].
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90).
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) [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 (DiscardingOutput) e4c51744f3711bfd6e299a26798b7e90.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (e4c51744f3711bfd6e299a26798b7e90) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1213220505-acbfab8a (1472f9a77897795a69f2372ba2131ad9) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 1472f9a77897795a69f2372ba2131ad9 reached globally terminal state FINISHED.
    [flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
    [flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_230.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1213220505-acbfab8a(1472f9a77897795a69f2372ba2131ad9).
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher02b0530c-887f-41a7-89f6-510137f68a68.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher02b0530c-887f-41a7-89f6-510137f68a68.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection c805fc1deee17f8d521546b247b00cee: JobManager is shutting down..
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-46440630-ee68-4181-b632-c2ba4edfa2d0
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcActor - The rpc endpoint org.apache.flink.runtime.jobmaster.slotpool.SlotPool has not been started yet. Discarding message org.apache.flink.runtime.rpc.messages.LocalRpcInvocation until processing is started.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 1472f9a77897795a69f2372ba2131ad9 with leader id 8ff94dba0c4a4ac772f3d577186844eb lost leadership.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_230.
    [ForkJoinPool.commonPool-worker-13] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher02b0530c-887f-41a7-89f6-510137f68a68.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:35855
    [flink-akka.actor.default-dispatcher-4] 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 13310 msecs
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1213220505-acbfab8a_16cc9778-4763-4689-a338-9a883d502eec/MANIFEST has 186 artifact locations
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1213220505-acbfab8a_16cc9778-4763-4689-a338-9a883d502eec/
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:39873
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:41625

Gradle Test Executor 2 finished executing tests.

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

org.apache.beam.sdk.transforms.join.CoGroupByKeyTest > testCoGroupByKey SKIPPED

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Daemon worker,5,main]) completed. Took 42 mins 54.72 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> Process 'Gradle Test Executor 1' finished with non-zero exit value 137
  This problem might be caused by incorrect test process configuration.
  Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution

* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.

* Get more help at https://help.gradle.org

Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings

BUILD FAILED in 46m 47s
75 actionable tasks: 71 executed, 3 from cache, 1 up-to-date

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

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

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


Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #176

Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/176/display/redirect>

------------------------------------------
[...truncated 421.87 MB...]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (12/16).
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (3e9d5d580a0216ea2b689b5c14f8e3f3) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (3e9d5d580a0216ea2b689b5c14f8e3f3) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (3e9d5d580a0216ea2b689b5c14f8e3f3) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (1/16) (3e9d5d580a0216ea2b689b5c14f8e3f3).
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (1/16) (3e9d5d580a0216ea2b689b5c14f8e3f3) [FINISHED]
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8) [DEPLOYING]
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8) [DEPLOYING].
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8) [DEPLOYING].
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (3/16).
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8).
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 59db454b364ec2aaf7111d76cb244143.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645) [DEPLOYING]
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (6/16) (59db454b364ec2aaf7111d76cb244143) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645) [DEPLOYING].
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (9/16).
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645).
    [DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 51cc97405ed9760cd5aa383698184f76.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a) switched from CREATED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 7c4a180200131816a17195d677f77243.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a) [DEPLOYING]
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) b75a328a7ba23db7fa1902e8763b964d.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16) (51cc97405ed9760cd5aa383698184f76) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a) [DEPLOYING].
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (16/16) (7c4a180200131816a17195d677f77243) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (6/16).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16) (b75a328a7ba23db7fa1902e8763b964d) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a).
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) aedb694e8b80245f6b6e586602f358fa.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca) [DEPLOYING]
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca) [DEPLOYING].
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca) [DEPLOYING].
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (13/16).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (4/16) (aedb694e8b80245f6b6e586602f358fa) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca).
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca) [FINISHED]
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d) [DEPLOYING]
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (16/16).
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d) [DEPLOYING].
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46) [DEPLOYING]
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46) [DEPLOYING].
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d).
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (2/16).
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 166b5562dc37db8b8eb305092edcb8b6.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 1ce8852ca3b8929ab6f0d8e6b1e54c10.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7) [DEPLOYING]
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7) [DEPLOYING].
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46).
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16) (166b5562dc37db8b8eb305092edcb8b6) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (4/16).
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16) (1ce8852ca3b8929ab6f0d8e6b1e54c10) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7).
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 65f54b94dce49c517914c9c1cda157ee.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7) [DEPLOYING]
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (5/16) (65f54b94dce49c517914c9c1cda157ee) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (15/16).
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7).
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7) [FINISHED]
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399) [DEPLOYING]
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399) [DEPLOYING].
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (5/16).
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399).
    [DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399) [FINISHED]
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72) [DEPLOYING]
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72) [DEPLOYING].
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72) [DEPLOYING].
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (14/16).
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72).
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 9ecbe77f6c45d1603c1bea0aa2c1bd65.
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72) [FINISHED]
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab) [DEPLOYING]
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 4c25c08c215f8cf0b5a3da4ec69cef00.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (9ecbe77f6c45d1603c1bea0aa2c1bd65) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 71fa254d39eb88c8cb74225dfd0db776.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab) [DEPLOYING].
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 3e9d5d580a0216ea2b689b5c14f8e3f3.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (4c25c08c215f8cf0b5a3da4ec69cef00) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 9668bd986f68847c7e25e121a7d5a4e8.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 09b3c03ec259040b09240160ecebf645.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (71fa254d39eb88c8cb74225dfd0db776) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab).
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 935c3e583afd654400437b636ad3f32a.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab) [FINISHED]
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) fe3d037baaa80ef49685c44079d412ca.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (3e9d5d580a0216ea2b689b5c14f8e3f3) 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 (DiscardingOutput) 29d7cdcf975adf0d1e4e96d6b7573e1d.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (9668bd986f68847c7e25e121a7d5a4e8) 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 (DiscardingOutput) 55eac9d15c80998d289453558ec98c46.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (09b3c03ec259040b09240160ecebf645) 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 (DiscardingOutput) 7911a57da711d3355b41d6fa4a2748f7.
    [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 (DiscardingOutput) 1c6fd51d606a90290c35e1171e1488f7.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (935c3e583afd654400437b636ad3f32a) 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 (DiscardingOutput) 74ef49e6cce5a23abbb4755e68a3d399.
    [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 (DiscardingOutput) fe7a2164502474805f8108b125309a72.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (fe3d037baaa80ef49685c44079d412ca) 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 (DiscardingOutput) b01ed31a336d2793ba236ddc7a178cab.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (29d7cdcf975adf0d1e4e96d6b7573e1d) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (55eac9d15c80998d289453558ec98c46) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (7911a57da711d3355b41d6fa4a2748f7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (1c6fd51d606a90290c35e1171e1488f7) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (74ef49e6cce5a23abbb4755e68a3d399) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (fe7a2164502474805f8108b125309a72) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (b01ed31a336d2793ba236ddc7a178cab) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (71fc938c1895151f25a9ee724f693d59) switched from RUNNING to FINISHED.
    [MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (71fc938c1895151f25a9ee724f693d59).
    [MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (71fc938c1895151f25a9ee724f693d59) [FINISHED]
    [jobmanager-future-thread-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) switched from CREATED to SCHEDULED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 71fc938c1895151f25a9ee724f693d59.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) switched from SCHEDULED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (71fc938c1895151f25a9ee724f693d59) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (8/16) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (8/16).
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) [DEPLOYING]
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) [DEPLOYING].
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) [DEPLOYING].
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd).
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) [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 (DiscardingOutput) 1dbfe90ab442a0dd17c3827d9d1803dd.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (1dbfe90ab442a0dd17c3827d9d1803dd) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1214004651-51518cb2 (0fc8bb4bc209d3e15c7f5d36c4cbf8e4) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 0fc8bb4bc209d3e15c7f5d36c4cbf8e4 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/dispatcher4a548f4c-99d9-4348-a2ba-e37d685b2a19.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1214004651-51518cb2(0fc8bb4bc209d3e15c7f5d36c4cbf8e4).
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_230.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher4a548f4c-99d9-4348-a2ba-e37d685b2a19.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 987d65999c8d144e92b46d6dd071161a: 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 0fc8bb4bc209d3e15c7f5d36c4cbf8e4 with leader id b570f687d4522614d9219105a12b4306 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-ef2c537d-0281-4938-adaf-da0e59c5acca
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher4a548f4c-99d9-4348-a2ba-e37d685b2a19.
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [ForkJoinPool.commonPool-worker-13] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_230.
    [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:33915
    [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 12119 msecs
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1214004651-51518cb2_9596863e-8ff3-461a-90b1-6f29b6f47ad8/MANIFEST has 186 artifact locations
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1214004651-51518cb2_9596863e-8ff3-461a-90b1-6f29b6f47ad8/
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:45617
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:44733

Gradle Test Executor 1 finished executing tests.

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

197 tests completed, 2 failed, 2 skipped
Finished generating test XML results (2.762 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/ws/src/runners/flink/job-server/build/test-results/validatesPortableRunnerBatch>
Generating HTML test report...
Finished generating test html results (1.522 secs) into: <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerBatch>

> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 6,5,main]) completed. Took 43 mins 57.226 secs.

FAILURE: Build failed with an exception.

* What went wrong:
Execution failed for task ':beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch'.
> There were failing tests. See the report at: file://<https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/ws/src/runners/flink/job-server/build/reports/tests/validatesPortableRunnerBatch/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 46m 54s
75 actionable tasks: 59 executed, 15 from cache, 1 up-to-date

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

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

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