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