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 08:39:46 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #135
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 #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