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: [email protected]
For additional commands, e-mail: [email protected]
