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/10 00:31:16 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #133
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/133/display/redirect>
------------------------------------------
[...truncated 193.48 MB...]
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (3/16) (18705f2f19fdf27ed1598e4f756908fe) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (10/16) (3b6678db3e2e26c22e2ca49e1c989c95) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (3/16) (18705f2f19fdf27ed1598e4f756908fe) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (10/16).
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (3/16) (18705f2f19fdf27ed1598e4f756908fe) [DEPLOYING].
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (18705f2f19fdf27ed1598e4f756908fe) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (18705f2f19fdf27ed1598e4f756908fe) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (754a0c6f99e62d31858e8acc11d82f9a) 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) (754a0c6f99e62d31858e8acc11d82f9a) [DEPLOYING]
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (10/16) (754a0c6f99e62d31858e8acc11d82f9a) [DEPLOYING].
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (10/16) (754a0c6f99e62d31858e8acc11d82f9a) [DEPLOYING].
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (754a0c6f99e62d31858e8acc11d82f9a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (4/16).
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (18705f2f19fdf27ed1598e4f756908fe) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (3/16) (18705f2f19fdf27ed1598e4f756908fe).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (754a0c6f99e62d31858e8acc11d82f9a) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (3/16) (18705f2f19fdf27ed1598e4f756908fe) [FINISHED]
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (754a0c6f99e62d31858e8acc11d82f9a) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (10/16) (754a0c6f99e62d31858e8acc11d82f9a).
[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 [2]PAssert$92/{RunChecks, VerifyAssertions}) 77d72138b65c67cc4335e858e5f8b7a6.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (10/16) (754a0c6f99e62d31858e8acc11d82f9a) [FINISHED]
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (3867e09bd5784f4436f8b797edb3e5c0) 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) (3867e09bd5784f4436f8b797edb3e5c0) [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) 1b22f5509bf8f2f8bcb9dff9b7d148d3.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (4/16) (77d72138b65c67cc4335e858e5f8b7a6) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (4/16) (3867e09bd5784f4436f8b797edb3e5c0) [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 [2]PAssert$90/{RunChecks, VerifyAssertions}) ded55f97b1cdde2f1e6470537b34fc05.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (1b22f5509bf8f2f8bcb9dff9b7d148d3) 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) db63b8c4654e9284a332af2c5093a90c.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (4/16) (ded55f97b1cdde2f1e6470537b34fc05) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (4/16) (3867e09bd5784f4436f8b797edb3e5c0) [DEPLOYING].
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (3867e09bd5784f4436f8b797edb3e5c0) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (db63b8c4654e9284a332af2c5093a90c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (3867e09bd5784f4436f8b797edb3e5c0) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (4/16).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) 51a964597e5716de77f1c0ceb2ae5448.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (3867e09bd5784f4436f8b797edb3e5c0) 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 [2]PAssert$92/{RunChecks, VerifyAssertions}) c66262dec2b06fff8b0547b1a99badab.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e) [DEPLOYING]
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (4/16) (3867e09bd5784f4436f8b797edb3e5c0).
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e) [DEPLOYING].
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (4/16) (3867e09bd5784f4436f8b797edb3e5c0) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (1/16) (51a964597e5716de77f1c0ceb2ae5448) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (12/16) (c66262dec2b06fff8b0547b1a99badab) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (12/16).
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e).
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e) [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 [2]PAssert$92/{RunChecks, VerifyAssertions}) 9b8573b6c0296bbf27216f54796c67d2.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (a9ccd47e93e0b5fe2fe21d6214981121) 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) (a9ccd47e93e0b5fe2fe21d6214981121) [DEPLOYING]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (11/16) (9b8573b6c0296bbf27216f54796c67d2) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (12/16) (a9ccd47e93e0b5fe2fe21d6214981121) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (1/16).
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (12/16) (a9ccd47e93e0b5fe2fe21d6214981121) [DEPLOYING].
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (a9ccd47e93e0b5fe2fe21d6214981121) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (a9ccd47e93e0b5fe2fe21d6214981121) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162) [DEPLOYING]
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162) [DEPLOYING].
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (11/16).
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (a9ccd47e93e0b5fe2fe21d6214981121) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (12/16) (a9ccd47e93e0b5fe2fe21d6214981121).
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b) [DEPLOYING]
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b) [DEPLOYING].
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162).
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (12/16) (a9ccd47e93e0b5fe2fe21d6214981121) [FINISHED]
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162) [FINISHED]
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (15/16).
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b) 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 [2]PAssert$92/{RunChecks, VerifyAssertions}) a06f3ead1bba14eaa84f809f483e083b.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (9b4e11cf9e5c2a875227735fb8c1b60f) 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) (9b4e11cf9e5c2a875227735fb8c1b60f) [DEPLOYING]
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b).
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (15/16) (9b4e11cf9e5c2a875227735fb8c1b60f) [DEPLOYING].
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (6/16) (a06f3ead1bba14eaa84f809f483e083b) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (15/16) (9b4e11cf9e5c2a875227735fb8c1b60f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (6/16).
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (9b4e11cf9e5c2a875227735fb8c1b60f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (9b4e11cf9e5c2a875227735fb8c1b60f) 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 [2]PAssert$92/{RunChecks, VerifyAssertions}) 398e1a4ebd1a098aaa21b42c0fb7588b.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (9b4e11cf9e5c2a875227735fb8c1b60f) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (15/16) (9b4e11cf9e5c2a875227735fb8c1b60f).
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (15/16) (9b4e11cf9e5c2a875227735fb8c1b60f) [FINISHED]
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e) [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) 247f0685f68d6f7d5b4301e979012ab4.
[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 [2]PAssert$89/{RunChecks, VerifyAssertions}) 68114f609c603673b7d43ab6201770d5.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (15/16) (398e1a4ebd1a098aaa21b42c0fb7588b) 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) 683bd01fd46c83049439fd996226e6d0.
[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 [2]PAssert$92/{RunChecks, VerifyAssertions}) 8b3af2aa81cda0716d134f694d05cb03.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (247f0685f68d6f7d5b4301e979012ab4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (10/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$89/{RunChecks, VerifyAssertions}) (10/16) (68114f609c603673b7d43ab6201770d5) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e) [DEPLOYING].
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (683bd01fd46c83049439fd996226e6d0) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (f8ef8b1efdf0c1e99967a7aab954d965) 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) (f8ef8b1efdf0c1e99967a7aab954d965) [DEPLOYING]
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (10/16) (f8ef8b1efdf0c1e99967a7aab954d965) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (5/16) (8b3af2aa81cda0716d134f694d05cb03) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e).
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e) [FINISHED]
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (5/16).
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (10/16) (f8ef8b1efdf0c1e99967a7aab954d965) [DEPLOYING].
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (f8ef8b1efdf0c1e99967a7aab954d965) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (f8ef8b1efdf0c1e99967a7aab954d965) 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) 6563626b5caa9834ead407b11e539ded.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (f8ef8b1efdf0c1e99967a7aab954d965) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (10/16) (f8ef8b1efdf0c1e99967a7aab954d965).
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1) [DEPLOYING]
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1) [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) acac98ce9fcacd5fb6ded62fc12e6ad7.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (10/16) (f8ef8b1efdf0c1e99967a7aab954d965) [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 [2]PAssert$92/{RunChecks, VerifyAssertions}) 71ead671e1771d88b23d7123fb8c5dfe.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (6563626b5caa9834ead407b11e539ded) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (acac98ce9fcacd5fb6ded62fc12e6ad7) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1) 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-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (14/16) (71ead671e1771d88b23d7123fb8c5dfe) 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) 3e989e7c42d409f92d70d5f4186b2c80.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1) 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) f88d1e21f7278f76d3c61e45777696b5.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223) [DEPLOYING]
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223) [DEPLOYING].
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1).
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1) [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) 18705f2f19fdf27ed1598e4f756908fe.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (3e989e7c42d409f92d70d5f4186b2c80) 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) 754a0c6f99e62d31858e8acc11d82f9a.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 3867e09bd5784f4436f8b797edb3e5c0.
[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) 2c56dbd57ced8f41cf773086b2a7d86e.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (f88d1e21f7278f76d3c61e45777696b5) 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) a9ccd47e93e0b5fe2fe21d6214981121.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223).
[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) b14266e062aa9be6189924567c3e8162.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (18705f2f19fdf27ed1598e4f756908fe) 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) 5654ddb7d7ff6e7cd18d89df92d6de4b.
[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) 9b4e11cf9e5c2a875227735fb8c1b60f.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (754a0c6f99e62d31858e8acc11d82f9a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223) 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) db169fe31856956c47f8446c2489dc8e.
[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) f8ef8b1efdf0c1e99967a7aab954d965.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (3867e09bd5784f4436f8b797edb3e5c0) 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) c1d265396ccbf1cdd82dc5e842894ca1.
[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) 3eb9be9b49e0426e28610a7bbf603223.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (2c56dbd57ced8f41cf773086b2a7d86e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (a9ccd47e93e0b5fe2fe21d6214981121) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (b14266e062aa9be6189924567c3e8162) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (5654ddb7d7ff6e7cd18d89df92d6de4b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (9b4e11cf9e5c2a875227735fb8c1b60f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (db169fe31856956c47f8446c2489dc8e) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (f8ef8b1efdf0c1e99967a7aab954d965) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (c1d265396ccbf1cdd82dc5e842894ca1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (3eb9be9b49e0426e28610a7bbf603223) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job countingsourcetest0testboundedsourcesplits-jenkins-1210003041-ddfb45c0 (88ef420f283463c7fbd93bb5183b3841) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 88ef420f283463c7fbd93bb5183b3841 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.jobmaster.JobMaster - Stopping the JobMaster for job countingsourcetest0testboundedsourcesplits-jenkins-1210003041-ddfb45c0(88ef420f283463c7fbd93bb5183b3841).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcheraac6e518-efc0-4658-963a-39faef0dd19c.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcheraac6e518-efc0-4658-963a-39faef0dd19c.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 80ae8f5bf5d94ebf42c784041d1b0bd8: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[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-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 88ef420f283463c7fbd93bb5183b3841 with leader id 89a27eae6053966b6a78deda84f9494f lost leadership.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-fb6f00b0-ddac-4c6b-8298-9003a8d3f06f
[flink-akka.actor.default-dispatcher-3] 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.taskexecutor.JobLeaderService - Stop job leader service.
[ForkJoinPool.commonPool-worker-6] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[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-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcheraac6e518-efc0-4658-963a-39faef0dd19c.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:43215
[flink-akka.actor.default-dispatcher-3] 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 10537 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1210003041-ddfb45c0_e3f80052-ac82-4391-a687-336076f692e3/MANIFEST has 186 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1210003041-ddfb45c0_e3f80052-ac82-4391-a687-336076f692e3/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:34651
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:36495
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.transforms.ParDoTest$TimerTests > testEventTimeTimerAbsolute SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 26 mins 30.739 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 30m 49s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/hdkdyreewqntm
Build cache (/home/jenkins/.gradle/caches/build-cache-1) removing files not accessed on or after Mon Dec 03 00:00:27 UTC 2018.
Invalidating in-memory cache of /home/jenkins/.gradle/caches/journal-1/file-access.bin
Build cache (/home/jenkins/.gradle/caches/build-cache-1) cleaned up in 3.843 secs.
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 #136
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/136/display/redirect?page=changes>
Changes:
[robertwb] [BEAM-4150] Use unwindowed coder in FnApiRunner optimization phases.
[robertwb] [BEAM-6186] Optimization cleanup: move phase utilities out of local
------------------------------------------
[...truncated 288.79 MB...]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (6/16) (3d9cffba81c8a78c3b18be69c28b1e33) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (c25940cf00f6cc02976ac010ce04eb22) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (fc6ee01f5480424a1b0edc7a7f7f231b) 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) (fc6ee01f5480424a1b0edc7a7f7f231b) [DEPLOYING]
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (3/16) (fc6ee01f5480424a1b0edc7a7f7f231b) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (6/16).
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (3/16) (fc6ee01f5480424a1b0edc7a7f7f231b) [DEPLOYING].
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (fc6ee01f5480424a1b0edc7a7f7f231b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 1394a048ab447a7b835f8a6b482afc2b.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (fc6ee01f5480424a1b0edc7a7f7f231b) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) fae098607b9dfb18b6a4a360dc5f25c1.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (d1a295a31baab11832a349e185bb15ad) 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) (d1a295a31baab11832a349e185bb15ad) [DEPLOYING]
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (6/16) (d1a295a31baab11832a349e185bb15ad) [DEPLOYING].
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (fc6ee01f5480424a1b0edc7a7f7f231b) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (3/16) (fc6ee01f5480424a1b0edc7a7f7f231b).
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (3/16) (fc6ee01f5480424a1b0edc7a7f7f231b) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (5/16) (1394a048ab447a7b835f8a6b482afc2b) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (6/16) (d1a295a31baab11832a349e185bb15ad) [DEPLOYING].
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (d1a295a31baab11832a349e185bb15ad) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (5/16).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16) (fae098607b9dfb18b6a4a360dc5f25c1) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (d1a295a31baab11832a349e185bb15ad) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (6/16) (d1a295a31baab11832a349e185bb15ad).
[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$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 190e5d8937d8d90e9dd6f98ac3c09f49.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (6/16) (d1a295a31baab11832a349e185bb15ad) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (d1a295a31baab11832a349e185bb15ad) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (9abc338ca3ba65b5845b2bd42b5c3e22) 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) (9abc338ca3ba65b5845b2bd42b5c3e22) [DEPLOYING]
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (5/16) (9abc338ca3ba65b5845b2bd42b5c3e22) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (16/16) (190e5d8937d8d90e9dd6f98ac3c09f49) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (5/16) (9abc338ca3ba65b5845b2bd42b5c3e22) [DEPLOYING].
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (9abc338ca3ba65b5845b2bd42b5c3e22) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (2/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (9abc338ca3ba65b5845b2bd42b5c3e22) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (9abc338ca3ba65b5845b2bd42b5c3e22) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (5/16) (9abc338ca3ba65b5845b2bd42b5c3e22).
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (5/16) (9abc338ca3ba65b5845b2bd42b5c3e22) [FINISHED]
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (98f7e68df8adf99db56a1948110528b4) 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) (98f7e68df8adf99db56a1948110528b4) [DEPLOYING]
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (2/16) (98f7e68df8adf99db56a1948110528b4) [DEPLOYING].
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (2/16) (98f7e68df8adf99db56a1948110528b4) [DEPLOYING].
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (98f7e68df8adf99db56a1948110528b4) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (12/16).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (98f7e68df8adf99db56a1948110528b4) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (98f7e68df8adf99db56a1948110528b4) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (2/16) (98f7e68df8adf99db56a1948110528b4).
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (2/16) (98f7e68df8adf99db56a1948110528b4) [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$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 4697927675474e448e51f921040a2d4a.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (d4ecf0727ad728b9ac16533ba4d0cfaa) 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) (d4ecf0727ad728b9ac16533ba4d0cfaa) [DEPLOYING]
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (12/16) (d4ecf0727ad728b9ac16533ba4d0cfaa) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16) (4697927675474e448e51f921040a2d4a) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (12/16) (d4ecf0727ad728b9ac16533ba4d0cfaa) [DEPLOYING].
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (d4ecf0727ad728b9ac16533ba4d0cfaa) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (13/16).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (d4ecf0727ad728b9ac16533ba4d0cfaa) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (d4ecf0727ad728b9ac16533ba4d0cfaa) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (12/16) (d4ecf0727ad728b9ac16533ba4d0cfaa).
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (12/16) (d4ecf0727ad728b9ac16533ba4d0cfaa) [FINISHED]
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (54414d9bcd838900784a5b6d529321ad) 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) (54414d9bcd838900784a5b6d529321ad) [DEPLOYING]
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (13/16) (54414d9bcd838900784a5b6d529321ad) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] 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) (54414d9bcd838900784a5b6d529321ad) [DEPLOYING].
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (54414d9bcd838900784a5b6d529321ad) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (54414d9bcd838900784a5b6d529321ad) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (54414d9bcd838900784a5b6d529321ad) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (13/16) (54414d9bcd838900784a5b6d529321ad).
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (13/16) (54414d9bcd838900784a5b6d529321ad) [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$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 9ecbd5a9b4619b591d84313a01d497fc.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (b60d2ee087695026c7c09d43deb5d712) 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) (b60d2ee087695026c7c09d43deb5d712) [DEPLOYING]
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (16/16) (b60d2ee087695026c7c09d43deb5d712) [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$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 818dc7a3f39e02bbbd1f96cbd6f31ea7.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (16/16) (b60d2ee087695026c7c09d43deb5d712) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16) (9ecbd5a9b4619b591d84313a01d497fc) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (b60d2ee087695026c7c09d43deb5d712) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (1/16) (818dc7a3f39e02bbbd1f96cbd6f31ea7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (1/16).
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (b60d2ee087695026c7c09d43deb5d712) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (16/16) (b60d2ee087695026c7c09d43deb5d712).
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (16/16) (b60d2ee087695026c7c09d43deb5d712) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (b60d2ee087695026c7c09d43deb5d712) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (fdb7ca4798da83dd484c1425883435b9) 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) (fdb7ca4798da83dd484c1425883435b9) [DEPLOYING]
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (1/16) (fdb7ca4798da83dd484c1425883435b9) [DEPLOYING].
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (1/16) (fdb7ca4798da83dd484c1425883435b9) [DEPLOYING].
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (fdb7ca4798da83dd484c1425883435b9) 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-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (fdb7ca4798da83dd484c1425883435b9) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (fdb7ca4798da83dd484c1425883435b9) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (1/16) (fdb7ca4798da83dd484c1425883435b9).
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (1/16) (fdb7ca4798da83dd484c1425883435b9) [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$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 45fb9ec839884e2cec20080c201914fd.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9) switched from CREATED to 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$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) a2f2bfaccf09c573775943c2d391bedc.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9) [DEPLOYING]
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (12/16) (45fb9ec839884e2cec20080c201914fd) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16) (a2f2bfaccf09c573775943c2d391bedc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9).
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (15/16).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 86838abb32e274140dbff52fc61a0f4f.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (eaafa7b49ddaf75245c4f476a8736928) 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) (eaafa7b49ddaf75245c4f476a8736928) [DEPLOYING]
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (15/16) (eaafa7b49ddaf75245c4f476a8736928) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) aeaa808f3822827fa2d978e617008483.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (15/16) (eaafa7b49ddaf75245c4f476a8736928) [DEPLOYING].
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (eaafa7b49ddaf75245c4f476a8736928) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (10/16) (86838abb32e274140dbff52fc61a0f4f) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (eaafa7b49ddaf75245c4f476a8736928) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (15/16) (eaafa7b49ddaf75245c4f476a8736928).
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (15/16) (eaafa7b49ddaf75245c4f476a8736928) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (10/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (aeaa808f3822827fa2d978e617008483) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (eaafa7b49ddaf75245c4f476a8736928) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 7643583b05823fded9f92dd1debba9e3.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) dc2201d664445c3e018857b5b2913c44.
[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) c25940cf00f6cc02976ac010ce04eb22.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5) [DEPLOYING]
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5) [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) fc6ee01f5480424a1b0edc7a7f7f231b.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (7643583b05823fded9f92dd1debba9e3) 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) d1a295a31baab11832a349e185bb15ad.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5) [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) 9abc338ca3ba65b5845b2bd42b5c3e22.
[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) 98f7e68df8adf99db56a1948110528b4.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (dc2201d664445c3e018857b5b2913c44) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5) 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) d4ecf0727ad728b9ac16533ba4d0cfaa.
[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) 54414d9bcd838900784a5b6d529321ad.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (c25940cf00f6cc02976ac010ce04eb22) 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) b60d2ee087695026c7c09d43deb5d712.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5).
[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) fdb7ca4798da83dd484c1425883435b9.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (fc6ee01f5480424a1b0edc7a7f7f231b) 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) 66d3dbc7c2624f94e4ac345828fe2ab9.
[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) eaafa7b49ddaf75245c4f476a8736928.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (d1a295a31baab11832a349e185bb15ad) 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) 22030fb36b38f17854ac14024a2ea1e5.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (9abc338ca3ba65b5845b2bd42b5c3e22) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (98f7e68df8adf99db56a1948110528b4) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (d4ecf0727ad728b9ac16533ba4d0cfaa) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (54414d9bcd838900784a5b6d529321ad) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (b60d2ee087695026c7c09d43deb5d712) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (fdb7ca4798da83dd484c1425883435b9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (66d3dbc7c2624f94e4ac345828fe2ab9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (eaafa7b49ddaf75245c4f476a8736928) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (22030fb36b38f17854ac14024a2ea1e5) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (3c19b79a7b3786db31e33614e28a6935) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (3c19b79a7b3786db31e33614e28a6935).
[MapPartition (MapPartition at [5]PAssert$155/{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$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (3c19b79a7b3786db31e33614e28a6935) [FINISHED]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 3c19b79a7b3786db31e33614e28a6935.
[jobmanager-future-thread-1] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (8/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$155/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (8/16) (3c19b79a7b3786db31e33614e28a6935) switched from RUNNING to FINISHED.
[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) (516df623a282d02ae19bca1bddddc503) 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) (516df623a282d02ae19bca1bddddc503) [DEPLOYING]
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503) [DEPLOYING].
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503) [DEPLOYING].
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503).
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503) [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) 516df623a282d02ae19bca1bddddc503.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (516df623a282d02ae19bca1bddddc503) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job reifytimestampstest0invaluessucceeds-jenkins-1210093804-28a10a9b (1bc56ee080ed1a34ac3b61fd9a33aece) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 1bc56ee080ed1a34ac3b61fd9a33aece 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-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_260.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job reifytimestampstest0invaluessucceeds-jenkins-1210093804-28a10a9b(1bc56ee080ed1a34ac3b61fd9a33aece).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher3fc5574b-ed33-48ba-95f5-23b8796ac457.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher3fc5574b-ed33-48ba-95f5-23b8796ac457.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 1dcf4742bc22633e04bc87bd2d4d7b22: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-2] 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-2] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 1bc56ee080ed1a34ac3b61fd9a33aece with leader id 8408370fb043300d91f8fd025e81442d lost leadership.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-43965ae8-ff91-4a3e-b0ec-2d65a4376e49
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher3fc5574b-ed33-48ba-95f5-23b8796ac457.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_260.
[ForkJoinPool.commonPool-worker-1] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[ForkJoinPool.commonPool-worker-1] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:39611
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkRunner - Execution finished in 13488 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/reifytimestampstest0invaluessucceeds-jenkins-1210093804-28a10a9b_b692d37f-5ec4-4afe-a74b-32c4c8a1341e/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-1210093804-28a10a9b_b692d37f-5ec4-4afe-a74b-32c4c8a1341e/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:45735
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:38413
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testCombiningStateParameterSuperclass SKIPPED
159 tests completed, 1 failed, 3 skipped
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 54 mins 0.255 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 58m 16s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/wxpvqkrwxr6zu
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 #135
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/135/display/redirect?page=changes>
Changes:
[robertwb] [BEAM-6167] Add class ReadFromTextWithFilename (Python) (#7193)
------------------------------------------
[...truncated 195.25 MB...]
[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 [2]PAssert$92/{RunChecks, VerifyAssertions}) 894cb192de7a8cbe73f1bd6ad53e4eb3.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (10/16) (894cb192de7a8cbe73f1bd6ad53e4eb3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (14/16).
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (5/16) (attempt #0) to localhost
[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 [2]PAssert$92/{RunChecks, VerifyAssertions}) f3da63415b47500daab20475916fc715.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (a4c9af95af42daecbb79d4685ad14f62) 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) (a4c9af95af42daecbb79d4685ad14f62) [DEPLOYING]
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (4/16) (f3da63415b47500daab20475916fc715) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (bbbd2a5277fa17220e3602a9e4ba35ad) 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) (bbbd2a5277fa17220e3602a9e4ba35ad) [DEPLOYING]
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (14/16) (a4c9af95af42daecbb79d4685ad14f62) [DEPLOYING].
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (11/16).
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (8/16) (bbbd2a5277fa17220e3602a9e4ba35ad) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (14/16) (a4c9af95af42daecbb79d4685ad14f62) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (a4c9af95af42daecbb79d4685ad14f62) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (8/16) (bbbd2a5277fa17220e3602a9e4ba35ad) [DEPLOYING].
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (a4c9af95af42daecbb79d4685ad14f62) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558) [DEPLOYING]
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558) [DEPLOYING].
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (bbbd2a5277fa17220e3602a9e4ba35ad) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (bbbd2a5277fa17220e3602a9e4ba35ad) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558) [DEPLOYING].
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (10/16).
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (8/16) (bbbd2a5277fa17220e3602a9e4ba35ad) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558).
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (8/16) (bbbd2a5277fa17220e3602a9e4ba35ad).
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558) [FINISHED]
[DataSink (DiscardingOutput) (8/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (8/16) (bbbd2a5277fa17220e3602a9e4ba35ad) [FINISHED]
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (67b5c8ccefeb6de0ce9198c666afa147) 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) (67b5c8ccefeb6de0ce9198c666afa147) [DEPLOYING]
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (10/16) (67b5c8ccefeb6de0ce9198c666afa147) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (16/16).
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (10/16) (67b5c8ccefeb6de0ce9198c666afa147) [DEPLOYING].
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (67b5c8ccefeb6de0ce9198c666afa147) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (67b5c8ccefeb6de0ce9198c666afa147) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (10/16) (67b5c8ccefeb6de0ce9198c666afa147) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (10/16) (67b5c8ccefeb6de0ce9198c666afa147).
[DataSink (DiscardingOutput) (10/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (10/16) (67b5c8ccefeb6de0ce9198c666afa147) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) ae5b1dcdd85f61d0bcbea1604edc2051.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (e6665102f730109b0ae735d8711b3d46) 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) (e6665102f730109b0ae735d8711b3d46) [DEPLOYING]
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (16/16) (e6665102f730109b0ae735d8711b3d46) [DEPLOYING].
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (16/16) (e6665102f730109b0ae735d8711b3d46) [DEPLOYING].
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (e6665102f730109b0ae735d8711b3d46) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (3/16) (ae5b1dcdd85f61d0bcbea1604edc2051) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (e6665102f730109b0ae735d8711b3d46) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (16/16) (e6665102f730109b0ae735d8711b3d46).
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (16/16) (e6665102f730109b0ae735d8711b3d46) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (7/16).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (e6665102f730109b0ae735d8711b3d46) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) 3f8131db1323cc9fc5ae67f9a186fe02.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) cca7c7849f1e35dde7c0c42a107beb07.
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (c0a70e79c02313d0a899e5a2750fc1f1) 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) (c0a70e79c02313d0a899e5a2750fc1f1) [DEPLOYING]
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (7/16) (c0a70e79c02313d0a899e5a2750fc1f1) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (13/16) (3f8131db1323cc9fc5ae67f9a186fe02) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (7/16) (c0a70e79c02313d0a899e5a2750fc1f1) [DEPLOYING].
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (c0a70e79c02313d0a899e5a2750fc1f1) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (3/16).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (6/16) (cca7c7849f1e35dde7c0c42a107beb07) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (c0a70e79c02313d0a899e5a2750fc1f1) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (c0a70e79c02313d0a899e5a2750fc1f1) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (7/16) (c0a70e79c02313d0a899e5a2750fc1f1).
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (7/16) (c0a70e79c02313d0a899e5a2750fc1f1) [FINISHED]
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (6cd8aa4abc168fdbbd5be646dc4faf30) 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) (6cd8aa4abc168fdbbd5be646dc4faf30) [DEPLOYING]
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (3/16) (6cd8aa4abc168fdbbd5be646dc4faf30) [DEPLOYING].
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (3/16) (6cd8aa4abc168fdbbd5be646dc4faf30) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (13/16).
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (6cd8aa4abc168fdbbd5be646dc4faf30) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (6cd8aa4abc168fdbbd5be646dc4faf30) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (6cd8aa4abc168fdbbd5be646dc4faf30) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (3/16) (6cd8aa4abc168fdbbd5be646dc4faf30).
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (3/16) (6cd8aa4abc168fdbbd5be646dc4faf30) [FINISHED]
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346) [DEPLOYING]
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (6/16).
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346) [DEPLOYING].
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) e127b91d51017a020e67880c9f2076ac.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346).
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346) [FINISHED]
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (42f452bab653c92b0e9a462a3605ff2a) 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) (42f452bab653c92b0e9a462a3605ff2a) [DEPLOYING]
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (6/16) (42f452bab653c92b0e9a462a3605ff2a) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (a4c9af95af42daecbb79d4685ad14f62) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (6/16) (42f452bab653c92b0e9a462a3605ff2a) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (14/16) (a4c9af95af42daecbb79d4685ad14f62).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (9/16) (e127b91d51017a020e67880c9f2076ac) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (42f452bab653c92b0e9a462a3605ff2a) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (14/16) (a4c9af95af42daecbb79d4685ad14f62) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (42f452bab653c92b0e9a462a3605ff2a) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (9/16).
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (42f452bab653c92b0e9a462a3605ff2a) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (6/16) (42f452bab653c92b0e9a462a3605ff2a).
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (6/16) (42f452bab653c92b0e9a462a3605ff2a) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) ae32a114943706ee79a1c442c084de82.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 5f1abe73e6bc6f46241311b8dcab822b.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) 9df1a92e0755f7042f93cefaa842d995.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (ae32a114943706ee79a1c442c084de82) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (5f1abe73e6bc6f46241311b8dcab822b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (1/16) (9df1a92e0755f7042f93cefaa842d995) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (1/16).
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (382545cd4cc136e16002ee6d4ff748d5) 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) (382545cd4cc136e16002ee6d4ff748d5) [DEPLOYING]
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (9/16) (382545cd4cc136e16002ee6d4ff748d5) [DEPLOYING].
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (2/16).
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (231996cd78273661c03000ab0ae3599c) 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) (231996cd78273661c03000ab0ae3599c) [DEPLOYING]
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (1/16) (231996cd78273661c03000ab0ae3599c) [DEPLOYING].
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (1/16) (231996cd78273661c03000ab0ae3599c) [DEPLOYING].
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (9/16) (382545cd4cc136e16002ee6d4ff748d5) [DEPLOYING].
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (231996cd78273661c03000ab0ae3599c) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (382545cd4cc136e16002ee6d4ff748d5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (382545cd4cc136e16002ee6d4ff748d5) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (231996cd78273661c03000ab0ae3599c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) 0ba710487eee1660098acd48c2b4256a.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 167bd9437e3e4d4a7f98b72a7213bdde.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd) [DEPLOYING]
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) 4c6c752622093886f8fa1464d0944855.
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (382545cd4cc136e16002ee6d4ff748d5) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (231996cd78273661c03000ab0ae3599c) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (9/16) (382545cd4cc136e16002ee6d4ff748d5).
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (1/16) (231996cd78273661c03000ab0ae3599c).
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (1/16) (231996cd78273661c03000ab0ae3599c) [FINISHED]
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (9/16) (382545cd4cc136e16002ee6d4ff748d5) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (2/16) (0ba710487eee1660098acd48c2b4256a) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd) [DEPLOYING].
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (167bd9437e3e4d4a7f98b72a7213bdde) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd).
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (5/16).
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$92/{RunChecks, VerifyAssertions}) (5/16) (4c6c752622093886f8fa1464d0944855) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) c0ed28cf963ee3fa3b80a125f163a558.
[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) bbbd2a5277fa17220e3602a9e4ba35ad.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671) 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) (19f9e6e06b588bd0ae89e727e9b65671) [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) 67b5c8ccefeb6de0ce9198c666afa147.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (c0ed28cf963ee3fa3b80a125f163a558) 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) e6665102f730109b0ae735d8711b3d46.
[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) c0a70e79c02313d0a899e5a2750fc1f1.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (bbbd2a5277fa17220e3602a9e4ba35ad) 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) 6cd8aa4abc168fdbbd5be646dc4faf30.
[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) 9b00ef3d21e174890ad528caa180c346.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (67b5c8ccefeb6de0ce9198c666afa147) 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) a4c9af95af42daecbb79d4685ad14f62.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671) [DEPLOYING].
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 42f452bab653c92b0e9a462a3605ff2a.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (e6665102f730109b0ae735d8711b3d46) 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) 382545cd4cc136e16002ee6d4ff748d5.
[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) 231996cd78273661c03000ab0ae3599c.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (c0a70e79c02313d0a899e5a2750fc1f1) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) e19ca027b13cf58788009634c2784bbd.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (6cd8aa4abc168fdbbd5be646dc4faf30) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671) [DEPLOYING].
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (9b00ef3d21e174890ad528caa180c346) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (a4c9af95af42daecbb79d4685ad14f62) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (42f452bab653c92b0e9a462a3605ff2a) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (382545cd4cc136e16002ee6d4ff748d5) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671).
[DataSink (DiscardingOutput) (5/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (231996cd78273661c03000ab0ae3599c) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 19f9e6e06b588bd0ae89e727e9b65671.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (e19ca027b13cf58788009634c2784bbd) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (19f9e6e06b588bd0ae89e727e9b65671) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job countingsourcetest0testboundedsourcesplits-jenkins-1210083917-7eef505d (94a151b1376e1f1eb581a49e8a9c527c) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 94a151b1376e1f1eb581a49e8a9c527c 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_102.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job countingsourcetest0testboundedsourcesplits-jenkins-1210083917-7eef505d(94a151b1376e1f1eb581a49e8a9c527c).
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher6a75fe5b-b4f1-4bae-84c3-9a91707dd652.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher6a75fe5b-b4f1-4bae-84c3-9a91707dd652.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection c5a7eadee93c200bdfdba035269b2326: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-8] 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-8] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[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-90adf509-4c4c-4658-b10f-299e9e73ad48
[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-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 94a151b1376e1f1eb581a49e8a9c527c with leader id ae56da52dfdcc442b2ca3671e7874710 lost leadership.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher6a75fe5b-b4f1-4bae-84c3-9a91707dd652.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[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_102.
[flink-akka.actor.default-dispatcher-5] 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:35711
[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 15369 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1210083917-7eef505d_81139d2c-22b0-46c0-a8a2-d3f9cac7eb26/MANIFEST has 186 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1210083917-7eef505d_81139d2c-22b0-46c0-a8a2-d3f9cac7eb26/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:34729
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:35235
Gradle Test Executor 1 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.transforms.ParDoTest$TimerTests > testAbsoluteProcessingTimeTimerRejected SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 11,5,main]) completed. Took 19 mins 53.754 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 2' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 23m 32s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/t22u2225gk2w6
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 #134
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/134/display/redirect>
------------------------------------------
[...truncated 48.08 MB...]
[jobmanager-future-thread-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) switched from CREATED to SCHEDULED.
[jobmanager-future-thread-15] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (7/16) (attempt #0) to localhost
[MapPartition (MapPartition at [5]PAssert$14/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]PAssert$14/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (16/16) (a060020a305462df13637d73014f2221) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-9] 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$14/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) a060020a305462df13637d73014f2221.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (16/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$14/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (7/16) (1bafbb7e81c3850ebd6355df02b127f5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$14/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (16/16) (a060020a305462df13637d73014f2221) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (7/16).
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) 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) (1d4f543d5cd7b91466e0969097fa7af2) [DEPLOYING]
[flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (16/16).
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) [DEPLOYING].
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) 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) (1655a16ded413f7e2b4524e0407e4e5f) [DEPLOYING]
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) [DEPLOYING].
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) [DEPLOYING].
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) [DEPLOYING].
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f).
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2).
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) [FINISHED]
[DataSink (DiscardingOutput) (7/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) [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) 1655a16ded413f7e2b4524e0407e4e5f.
[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) 1d4f543d5cd7b91466e0969097fa7af2.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (1655a16ded413f7e2b4524e0407e4e5f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (1d4f543d5cd7b91466e0969097fa7af2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job pardotest0statetests0testvaluestatesameid-jenkins-1210061100-d410bf69 (e42886fe4dd1cabbe470fb777482adc1) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job e42886fe4dd1cabbe470fb777482adc1 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-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher3993aef1-3a6b-4844-b627-4d0e7bf4fdd2.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_22.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher3993aef1-3a6b-4844-b627-4d0e7bf4fdd2.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job pardotest0statetests0testvaluestatesameid-jenkins-1210061100-d410bf69(e42886fe4dd1cabbe470fb777482adc1).
[flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 365bd8c76b4a7c87171312e7cf07a25c: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-8] 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-8] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job e42886fe4dd1cabbe470fb777482adc1 with leader id 92f2a3428ed538fca1800b0f3d28471b lost leadership.
[ForkJoinPool.commonPool-worker-9] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher3993aef1-3a6b-4844-b627-4d0e7bf4fdd2.
org.apache.beam.sdk.testing.PAssertTest > testGlobalWindowContainsInAnyOrder STANDARD_ERROR
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/passerttest0testglobalwindowcontainsinanyorder-jenkins-1210061057-701c19f0_586f2c02-9c0d-4414-bb4e-f619a25d869c/
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testValueStateSameId STANDARD_ERROR
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-f913b74d-6f44-431e-95d6-9d0fe5375314
[flink-akka.actor.default-dispatcher-6] 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.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_22.
[flink-akka.actor.default-dispatcher-6] 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:40089
[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 24039 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/pardotest0statetests0testvaluestatesameid-jenkins-1210061100-d410bf69_783d8333-2816-45a2-a0d2-e10deca5a16d/MANIFEST has 186 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/pardotest0statetests0testvaluestatesameid-jenkins-1210061100-d410bf69_783d8333-2816-45a2-a0d2-e10deca5a16d/
org.apache.beam.sdk.testing.PAssertTest > testGlobalWindowContainsInAnyOrder STANDARD_ERROR
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:40869
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:41573
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testValueStateSameId STANDARD_ERROR
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:36213
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:34711
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testValueStateSimple STANDARD_ERROR
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingService started on localhost:44993
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobService started on localhost:42055
org.apache.beam.sdk.testing.PAssertTest > testWindowedSerializablePredicate STANDARD_ERROR
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingService started on localhost:39045
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobService started on localhost:41679
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testValueStateSimple STANDARD_ERROR
[Test worker] INFO org.apache.beam.runners.reference.PortableRunner - Using job server endpoint: localhost:42055
[Test worker] INFO org.apache.beam.runners.reference.PortableRunner - PrepareJobResponse: preparation_id: "pardotest0statetests0testvaluestatesimple-jenkins-1210061137-b3de5665_3e15be88-bf64-45ca-84cd-7561c5af3561"
artifact_staging_endpoint {
url: "localhost:44993"
}
staging_session_token: "{\"sessionId\":\"pardotest0statetests0testvaluestatesimple-jenkins-1210061137-b3de5665_3e15be88-bf64-45ca-84cd-7561c5af3561\",\"basePath\":\"/tmp/beam-artifact-staging\"}"
[Test worker] INFO org.apache.beam.runners.core.construction.ArtifactServiceStager - Staging 186 files (token: {"sessionId":"pardotest0statetests0testvaluestatesimple-jenkins-1210061137-b3de5665_3e15be88-bf64-45ca-84cd-7561c5af3561","basePath":"/tmp/beam-artifact-staging"})
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007fdc9bf40000, 65536, 1) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 12288 bytes for committing reserved memory.
[thread 140199763703552 also had an error]
[thread 140204255979264 also had an error]
[thread 140197374109440 also had an error]
[thread 140198553646848 also had an error]
[thread 140197395162880 also had an error]
[thread 140203653052160 also had an error]
[thread 140209479579392 also had an error]
[thread 140198566278912 also had an error]
[thread 140198587332352 also had an error]
[thread 140197357266688 also had an error]
[thread 140197370951424 also had an error]
[thread 140197384636160 also had an error]
[thread 140198556804864 also had an error]
[thread 140200140310272 also had an error]
[thread 140198544172800 also had an error]
[thread 140197377267456 also had an error]
[thread 140197356214016 also had an error]
[thread 140198546278144 also had an error]
[thread 140198538909440 also had an error]
[thread 140198541014784 also had an error]
[thread 140197393057536 also had an error]
[thread 140198557857536 also had an error]
[thread 140197382530816 also had an error]
[thread 140203986491136 also had an error]
[thread 140197369898752 also had an error]
[thread 140197329897216 also had an error]
[thread 140198564173568 also had an error]
[thread 140197386741504 also had an error]
[thread 140197364635392 also had an error]
[thread 140198550488832 also had an error]
[thread 140198569436928 also had an error]
[thread 140198565226240 also had an error]
[thread 140198561015552 also had an error]
[thread 140198578910976 also had an error]
[thread 140197373056768 also had an error]
[thread 140204244399872 also had an error]
#
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823f7f8000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:42055
[thread 140198676301568 also had an error]
# There is insufficient memory for the Java Runtime Environment to continue.
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82cd0cf000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
[thread 140197365688064 also had an error]
# Native memory allocation (mmap) failed to map 65536 bytes for committing reserved memory.
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f83d8cfa000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
# An error report file with more information is saved as:
# An error report file with more information is saved as:
# <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/ws/src/runners/flink/job-server/hs_err_pid7166.log>
# <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/ws/src/runners/flink/job-server/hs_err_pid7167.log>
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823e9ea000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f8284ecf000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823fdfe000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f83b4dfb000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f8510297000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f8285adb000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f8286eef000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823d9da000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823e6e7000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823f3f4000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82851d2000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82e37f8000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82845c6000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823eced000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823d8d9000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82847c8000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82840c1000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82842c3000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823fbfc000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82852d3000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823f1f2000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f83c8bf9000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823e5e6000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823bfc0000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82858d9000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823f5f6000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823e0e1000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f8284bcc000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f8285dde000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82859da000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82855d6000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f82866e7000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823e8e9000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f83d81ef000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f828c3c8000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00007f823e1e2000, 12288, 0) failed; error='Cannot allocate memory' (errno=12)
#
# Compiler replay data is saved as:
# <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/ws/src/runners/flink/job-server/replay_pid7167.log>
Could not stop org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@22038a9.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message [MethodInvocation method: stop()].
at org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:34)
at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:31)
at org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:133)
at org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:34)
at org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:73)
at org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test Executor 1' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
at org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:155)
at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:29)
... 10 more
org.apache.beam.sdk.transforms.ParDoTest$StateTests > testValueStateSimple SKIPPED
org.apache.beam.sdk.testing.PAssertTest > testWindowedSerializablePredicate SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 4,5,main]) completed. Took 7 mins 0.931 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 2' finished with non-zero exit value 1
This problem might be caused by incorrect test process configuration.
Please refer to the test execution section in the user guide at https://docs.gradle.org/4.10.2/userguide/java_plugin.html#sec:test_execution
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with Gradle 5.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See https://docs.gradle.org/4.10.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 11m 44s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/57lejg4wh7t44
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