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/18 20:28:43 UTC

Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #217

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

Changes:

[xinyuliu.us] [BEAM-6252] SamzaRunner: Add a registrar to allow customized DoFnInvoker

[xinyuliu.us] Allow Samza DoFnInvoker to generate configs and pass in TaskContext

[xinyuliu.us] [BEAM-6253] SamzaRunner: Add a few customized transforms for runner use

------------------------------------------
[...truncated 417.54 MB...]
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (94646345e0907e83fb67f32f14a8522b) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (13/16) (attempt #0) to localhost
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (94646345e0907e83fb67f32f14a8522b) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (94646345e0907e83fb67f32f14a8522b) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (12/16) (94646345e0907e83fb67f32f14a8522b).
    [DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (12/16) (94646345e0907e83fb67f32f14a8522b) [FINISHED]
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648) [DEPLOYING]
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648) [DEPLOYING].
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648) [DEPLOYING].
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (7/16).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648).
    [DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648) [FINISHED]
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (ce3716ef2c45a2ea70ddefaa1dc5b4a8) 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) (ce3716ef2c45a2ea70ddefaa1dc5b4a8) [DEPLOYING]
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (7/16) (ce3716ef2c45a2ea70ddefaa1dc5b4a8) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (4/16).
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (7/16) (ce3716ef2c45a2ea70ddefaa1dc5b4a8) [DEPLOYING].
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (ce3716ef2c45a2ea70ddefaa1dc5b4a8) 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}) 477ce63bb58e6d1e9c40d9478cb443f0.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (ce3716ef2c45a2ea70ddefaa1dc5b4a8) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (2ed55fa54f2a4525ee5e5e98875242ca) 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) (2ed55fa54f2a4525ee5e5e98875242ca) [DEPLOYING]
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (4/16) (2ed55fa54f2a4525ee5e5e98875242ca) [DEPLOYING].
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (ce3716ef2c45a2ea70ddefaa1dc5b4a8) 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}) (5/16) (477ce63bb58e6d1e9c40d9478cb443f0) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (7/16) (ce3716ef2c45a2ea70ddefaa1dc5b4a8).
    [DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (7/16) (ce3716ef2c45a2ea70ddefaa1dc5b4a8) [FINISHED]
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (4/16) (2ed55fa54f2a4525ee5e5e98875242ca) [DEPLOYING].
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (2ed55fa54f2a4525ee5e5e98875242ca) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (2ed55fa54f2a4525ee5e5e98875242ca) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (5/16).
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (2ed55fa54f2a4525ee5e5e98875242ca) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (4/16) (2ed55fa54f2a4525ee5e5e98875242ca).
    [DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (4/16) (2ed55fa54f2a4525ee5e5e98875242ca) [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}) 47c273588fe66976e8a8211aaca78d17.
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (69195daaa20b83817c8ff5f73b9f600d) 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) (69195daaa20b83817c8ff5f73b9f600d) [DEPLOYING]
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (5/16) (69195daaa20b83817c8ff5f73b9f600d) [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}) b95207831dd6f1a12c5b7fe7e01544e2.
    [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) d8a10ec2208d05598a65d7e53fd987e1.
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (5/16) (69195daaa20b83817c8ff5f73b9f600d) [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}) aa078dcaa1a2de1c7049343e6c46edce.
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (69195daaa20b83817c8ff5f73b9f600d) 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}) (9/16) (47c273588fe66976e8a8211aaca78d17) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (69195daaa20b83817c8ff5f73b9f600d) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (5/16) (69195daaa20b83817c8ff5f73b9f600d).
    [DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (5/16) (69195daaa20b83817c8ff5f73b9f600d) [FINISHED]
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (9/16).
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (6/16) (b95207831dd6f1a12c5b7fe7e01544e2) 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 MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) d43b044859a7c14c8be613c1892446cd.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (19e03809a143908bf4ff3c8226fdac7c) 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) (19e03809a143908bf4ff3c8226fdac7c) [DEPLOYING]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (d8a10ec2208d05598a65d7e53fd987e1) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (9/16) (19e03809a143908bf4ff3c8226fdac7c) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (69195daaa20b83817c8ff5f73b9f600d) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (9/16) (19e03809a143908bf4ff3c8226fdac7c) [DEPLOYING].
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (19e03809a143908bf4ff3c8226fdac7c) 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}) (10/16) (aa078dcaa1a2de1c7049343e6c46edce) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (6/16).
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (19e03809a143908bf4ff3c8226fdac7c) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (9/16) (19e03809a143908bf4ff3c8226fdac7c).
    [DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (9/16) (19e03809a143908bf4ff3c8226fdac7c) [FINISHED]
    [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) (d43b044859a7c14c8be613c1892446cd) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (19e03809a143908bf4ff3c8226fdac7c) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (b9127a9af9eba07d694d2c0334b011d6) 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) (b9127a9af9eba07d694d2c0334b011d6) [DEPLOYING]
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (6/16) (b9127a9af9eba07d694d2c0334b011d6) [DEPLOYING].
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (6/16) (b9127a9af9eba07d694d2c0334b011d6) [DEPLOYING].
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (b9127a9af9eba07d694d2c0334b011d6) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] 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) (6/16) (b9127a9af9eba07d694d2c0334b011d6) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (b9127a9af9eba07d694d2c0334b011d6) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (6/16) (b9127a9af9eba07d694d2c0334b011d6).
    [DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (6/16) (b9127a9af9eba07d694d2c0334b011d6) [FINISHED]
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (cdce4c036b6994174a968a5786566767) 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) (cdce4c036b6994174a968a5786566767) [DEPLOYING]
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (10/16) (cdce4c036b6994174a968a5786566767) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (2/16).
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (10/16) (cdce4c036b6994174a968a5786566767) [DEPLOYING].
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (cdce4c036b6994174a968a5786566767) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (cdce4c036b6994174a968a5786566767) 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) 18b933496836fd9efe21ca05dabc218f.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 97b874fb4d8c76a8faa954fe603d803a.
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (cdce4c036b6994174a968a5786566767) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (10/16) (cdce4c036b6994174a968a5786566767).
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a) switched from CREATED to DEPLOYING.
    [DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (10/16) (cdce4c036b6994174a968a5786566767) [FINISHED]
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a) [DEPLOYING]
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (18b933496836fd9efe21ca05dabc218f) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a) [DEPLOYING].
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (16/16) (97b874fb4d8c76a8faa954fe603d803a) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (16/16).
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a).
    [DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a) [FINISHED]
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 9a9a0ca88fccab229c066db40a8890f2.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (eff768bedfb268be593a937baf585ee5) 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) (eff768bedfb268be593a937baf585ee5) [DEPLOYING]
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (16/16) (eff768bedfb268be593a937baf585ee5) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 2c85f85259f089a93b1900e1eec42157.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 3f087d293cb4a8259a95da0b64660539.
    [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) (9a9a0ca88fccab229c066db40a8890f2) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (16/16) (eff768bedfb268be593a937baf585ee5) [DEPLOYING].
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (eff768bedfb268be593a937baf585ee5) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (2c85f85259f089a93b1900e1eec42157) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (14/16).
    [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) (3f087d293cb4a8259a95da0b64660539) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (eff768bedfb268be593a937baf585ee5) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (16/16) (eff768bedfb268be593a937baf585ee5).
    [DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (16/16) (eff768bedfb268be593a937baf585ee5) [FINISHED]
    [flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (eff768bedfb268be593a937baf585ee5) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (99bb6badc49823031d8d1f05eeb530d4) 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) (99bb6badc49823031d8d1f05eeb530d4) [DEPLOYING]
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (14/16) (99bb6badc49823031d8d1f05eeb530d4) [DEPLOYING].
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (14/16) (99bb6badc49823031d8d1f05eeb530d4) [DEPLOYING].
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (99bb6badc49823031d8d1f05eeb530d4) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (99bb6badc49823031d8d1f05eeb530d4) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (13/16).
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (99bb6badc49823031d8d1f05eeb530d4) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (14/16) (99bb6badc49823031d8d1f05eeb530d4).
    [DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (14/16) (99bb6badc49823031d8d1f05eeb530d4) [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) 94646345e0907e83fb67f32f14a8522b.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c) switched from CREATED to DEPLOYING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) dd8ec4b97bb536a35c1338fa2c3a2648.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c) [DEPLOYING]
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) ce3716ef2c45a2ea70ddefaa1dc5b4a8.
    [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) 2ed55fa54f2a4525ee5e5e98875242ca.
    [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) 69195daaa20b83817c8ff5f73b9f600d.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (94646345e0907e83fb67f32f14a8522b) 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) 19e03809a143908bf4ff3c8226fdac7c.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c) [DEPLOYING].
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) b9127a9af9eba07d694d2c0334b011d6.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c) 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) cdce4c036b6994174a968a5786566767.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (dd8ec4b97bb536a35c1338fa2c3a2648) 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) 4d5a23342ffc828a923a6b5a954f5a2a.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c) 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) eff768bedfb268be593a937baf585ee5.
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c).
    [DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c) [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) 99bb6badc49823031d8d1f05eeb530d4.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (ce3716ef2c45a2ea70ddefaa1dc5b4a8) 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) 01bcd605011dd29fdd0d5cb457b59c3c.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (2ed55fa54f2a4525ee5e5e98875242ca) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (69195daaa20b83817c8ff5f73b9f600d) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (19e03809a143908bf4ff3c8226fdac7c) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (b9127a9af9eba07d694d2c0334b011d6) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (cdce4c036b6994174a968a5786566767) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (4d5a23342ffc828a923a6b5a954f5a2a) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (eff768bedfb268be593a937baf585ee5) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (99bb6badc49823031d8d1f05eeb530d4) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (01bcd605011dd29fdd0d5cb457b59c3c) 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) (10f0fbbce29d4d3b883a960f8ae98b7a) 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) (10f0fbbce29d4d3b883a960f8ae98b7a).
    [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) (10f0fbbce29d4d3b883a960f8ae98b7a) [FINISHED]
    [jobmanager-future-thread-15] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe) switched from CREATED to SCHEDULED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$132/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 10f0fbbce29d4d3b883a960f8ae98b7a.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe) 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) (10f0fbbce29d4d3b883a960f8ae98b7a) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-7] 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) (710ef4081c19176aaf4bc3277baeddfe) 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) (710ef4081c19176aaf4bc3277baeddfe) [DEPLOYING]
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe) [DEPLOYING].
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe) [DEPLOYING].
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe) switched from DEPLOYING to RUNNING.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe) switched from DEPLOYING to RUNNING.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe) switched from RUNNING to FINISHED.
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe).
    [DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe) [FINISHED]
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 710ef4081c19176aaf4bc3277baeddfe.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (710ef4081c19176aaf4bc3277baeddfe) switched from RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1218202806-223099c3 (bcc02fc24e9b1c0850c1701119e6a324) switched from state RUNNING to FINISHED.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job bcc02fc24e9b1c0850c1701119e6a324 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-5] 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-1218202806-223099c3(bcc02fc24e9b1c0850c1701119e6a324).
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatchera277ee92-1e42-494c-b091-68c5c5381143.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatchera277ee92-1e42-494c-b091-68c5c5381143.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
    [flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
    [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 9b50a3f2c96090dae3697349b0162a71: 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 bcc02fc24e9b1c0850c1701119e6a324 with leader id a003e0d4e07481264abada2f458e448c lost leadership.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-843fa786-063f-4e33-97d1-15999631c9cf
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
    [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/dispatchera277ee92-1e42-494c-b091-68c5c5381143.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_230.
    [ForkJoinPool.commonPool-worker-8] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
    [ForkJoinPool.commonPool-worker-8] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
    [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:34995
    [flink-akka.actor.default-dispatcher-5] 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 12921 msecs
    [flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1218202806-223099c3_a6c59c76-9e86-458d-93ae-7dfc5e4d3a7c/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-1218202806-223099c3_a6c59c76-9e86-458d-93ae-7dfc5e4d3a7c/
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:33991
    [Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:40469

Gradle Test Executor 1 finished executing tests.

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

197 tests completed, 1 failed, 2 skipped
Finished generating test XML results (3.313 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.461 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 2,5,main]) completed. Took 44 mins 23.236 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 47m 25s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date

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

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