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/09 00:28:52 UTC
Build failed in Jenkins: beam_PostCommit_Java_PVR_Flink_Batch #129
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/129/display/redirect>
------------------------------------------
[...truncated 139.21 MB...]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) b3ee1629af27a01fad03da95dbd70603.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 0ab5f0a45311d2b1c190ed0c2b12f87f.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (04e11b1b152a11f0c7b0ae841c1c0648) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) [DEPLOYING].
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (b3ee1629af27a01fad03da95dbd70603) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4).
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) [FINISHED]
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (0ab5f0a45311d2b1c190ed0c2b12f87f) 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) dc5e1675d45c53034d352ff8bda5b4f4.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (dc5e1675d45c53034d352ff8bda5b4f4) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16) (5ffcba28450115bf71837e8d9ff4a9fe) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16) (5ffcba28450115bf71837e8d9ff4a9fe).
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16) (5ffcba28450115bf71837e8d9ff4a9fe) [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$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 5ffcba28450115bf71837e8d9ff4a9fe.
[jobmanager-future-thread-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (13/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (13/16) (5ffcba28450115bf71837e8d9ff4a9fe) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (13/16).
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) 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) (b528999c3b25970dbf73a8daf472673c) [DEPLOYING]
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) [DEPLOYING].
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) [DEPLOYING].
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16) (05746ceb9b72a2a3c63438818fc5ffa8) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16) (05746ceb9b72a2a3c63438818fc5ffa8).
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c).
[jobmanager-future-thread-10] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16) (05746ceb9b72a2a3c63438818fc5ffa8) [FINISHED]
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 05746ceb9b72a2a3c63438818fc5ffa8.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (2/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) b528999c3b25970dbf73a8daf472673c.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$78/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (2/16) (05746ceb9b72a2a3c63438818fc5ffa8) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16) (eecf93ca92c9253075414215033832c2) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16) (eecf93ca92c9253075414215033832c2).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (b528999c3b25970dbf73a8daf472673c) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16) (eecf93ca92c9253075414215033832c2) [FINISHED]
[jobmanager-future-thread-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (2/16).
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (15/16) (attempt #0) to localhost
[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 [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) eecf93ca92c9253075414215033832c2.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) 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) (a221f1fc5e2597d3702f38d5ee4b6a60) [DEPLOYING]
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (15/16) (eecf93ca92c9253075414215033832c2) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) [DEPLOYING].
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (15/16).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60).
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) [FINISHED]
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) 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) (f14bf5d1ddbc92dd809a088839ce16bd) [DEPLOYING]
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) [DEPLOYING].
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (4/16) (d2edf14a2b863abbc04e3860f82545bc) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (4/16) (d2edf14a2b863abbc04e3860f82545bc).
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (4/16) (d2edf14a2b863abbc04e3860f82545bc) [FINISHED]
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) [DEPLOYING].
[jobmanager-future-thread-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from CREATED to SCHEDULED.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (4/16) (attempt #0) to localhost
[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) a221f1fc5e2597d3702f38d5ee4b6a60.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd).
[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$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) d2edf14a2b863abbc04e3860f82545bc.
[DataSink (DiscardingOutput) (15/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) [FINISHED]
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (a221f1fc5e2597d3702f38d5ee4b6a60) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (4/16) (d2edf14a2b863abbc04e3860f82545bc) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (4/16).
[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) f14bf5d1ddbc92dd809a088839ce16bd.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) [DEPLOYING]
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (f14bf5d1ddbc92dd809a088839ce16bd) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) [DEPLOYING].
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3).
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) ec899b05458a7ffba12e3ae3353bdba3.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (ec899b05458a7ffba12e3ae3353bdba3) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16) (087f4b1b31d9c67a7cd1102470382dc5) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16) (087f4b1b31d9c67a7cd1102470382dc5).
[MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16) (087f4b1b31d9c67a7cd1102470382dc5) [FINISHED]
[jobmanager-future-thread-10] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) 087f4b1b31d9c67a7cd1102470382dc5.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (14/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [5]PAssert$76/{GroupGlobally, GetPane, RunChecks, VerifyAssertions}) (14/16) (087f4b1b31d9c67a7cd1102470382dc5) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (14/16).
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) 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) (d819f09a6086f0439dcce596e89150a2) [DEPLOYING]
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) [DEPLOYING].
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2).
[DataSink (DiscardingOutput) (14/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) [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) d819f09a6086f0439dcce596e89150a2.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (d819f09a6086f0439dcce596e89150a2) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job pardotest0multipleinputsandoutputtests0testpardowithtaggedoutput-jenkins-1209002812-fe4b69d (2a4ea4345883a88d1258995dcae79622) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 2a4ea4345883a88d1258995dcae79622 reached globally terminal state FINISHED.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcherdd828368-1b34-46bb-91ea-7e70bb6e088c.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_90.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job pardotest0multipleinputsandoutputtests0testpardowithtaggedoutput-jenkins-1209002812-fe4b69d(2a4ea4345883a88d1258995dcae79622).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-7] 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/dispatcherdd828368-1b34-46bb-91ea-7e70bb6e088c.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 8b666e580f3c15bf472d13092e1428ff: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-17773f69-24d4-4238-bd98-6c929aa0f1e9
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.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.
[ForkJoinPool.commonPool-worker-8] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 2a4ea4345883a88d1258995dcae79622 with leader id 92f4c70ed65214167252714114f342bf lost leadership.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-8] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcherdd828368-1b34-46bb-91ea-7e70bb6e088c.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_90.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:36743
[flink-akka.actor.default-dispatcher-7] 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 16319 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/pardotest0multipleinputsandoutputtests0testpardowithtaggedoutput-jenkins-1209002812-fe4b69d_fe0a40a2-617e-4d6d-be3a-dd5fbc176d49/MANIFEST has 186 artifact locations
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactStagingService - Removed dir /tmp/beam-artifact-staging/pardotest0multipleinputsandoutputtests0testpardowithtaggedoutput-jenkins-1209002812-fe4b69d_fe0a40a2-617e-4d6d-be3a-dd5fbc176d49/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:40833
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:43909
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests > testMultiOutputParDoWithSideInputsIsCumulative STANDARD_ERROR
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingService started on localhost:44523
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobService started on localhost:46461
[Test worker] INFO org.apache.beam.runners.reference.PortableRunner - Using job server endpoint: localhost:46461
[Test worker] INFO org.apache.beam.runners.reference.PortableRunner - PrepareJobResponse: preparation_id: "pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_7cd84ea3-0ede-4cad-9d7e-dd91807db38e"
artifact_staging_endpoint {
url: "localhost:44523"
}
staging_session_token: "{\"sessionId\":\"pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_7cd84ea3-0ede-4cad-9d7e-dd91807db38e\",\"basePath\":\"/tmp/beam-artifact-staging\"}"
[Test worker] INFO org.apache.beam.runners.core.construction.ArtifactServiceStager - Staging 186 files (token: {"sessionId":"pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_7cd84ea3-0ede-4cad-9d7e-dd91807db38e","basePath":"/tmp/beam-artifact-staging"})
[Test worker] INFO org.apache.beam.runners.core.construction.ArtifactServiceStager - Staged 186 files (token: {"sessionId":"pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_7cd84ea3-0ede-4cad-9d7e-dd91807db38e","basePath":"/tmp/beam-artifact-staging"})
[grpc-default-executor-220] INFO org.apache.beam.runners.flink.FlinkJobInvoker - Invoking job pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_bc37553f-a995-49b4-bddd-fa558c15ceb3
[grpc-default-executor-220] INFO org.apache.beam.runners.flink.FlinkJobInvocation - Starting job invocation pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_bc37553f-a995-49b4-bddd-fa558c15ceb3
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkJobInvocation - Translating pipeline to Flink program.
[Test worker] INFO org.apache.beam.runners.reference.PortableRunner - RunJobResponse: job_id: "pardotest0multipleinputsandoutputtests0testmultioutputpardowithsideinputsiscumulative-jenkins-1209002834-2ca25140_bc37553f-a995-49b4-bddd-fa558c15ceb3"
[flink-runner-job-server] INFO org.apache.beam.runners.flink.FlinkExecutionEnvironments - Creating a Batch Execution Environment.
[flink-runner-job-server] INFO org.apache.flink.api.java.ExecutionEnvironment - The job has 0 registered types and 0 default Kryo serializers
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Flink Mini Cluster
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Metrics Registry
[flink-runner-job-server] INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter configured, no metrics will be exposed/reported.
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting RPC Service(s)
[flink-akka.actor.default-dispatcher-3] INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting high-availability services
[flink-runner-job-server] INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /tmp/blobStore-6c69d45c-59f9-4a49-9d08-8cdc971f3a86
[flink-runner-job-server] INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:37245 - max concurrent requests: 50 - max backlog: 1000
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting ResourceManger
[flink-runner-job-server] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/resourcemanager_679813f2-746e-4abf-8940-d45a8b975dab .
[flink-runner-job-server] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.resourcemanager.StandaloneResourceManager@14702078 @ akka://flink/user/resourcemanager_679813f2-746e-4abf-8940-d45a8b975dab
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - ResourceManager akka://flink/user/resourcemanager_679813f2-746e-4abf-8940-d45a8b975dab was granted leadership with fencing token b8ceeadc1985c4b8788dcaccafb54170
[flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Starting the SlotManager.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/resourcemanager_679813f2-746e-4abf-8940-d45a8b975dab , session=788dcacc-afb5-4170-b8ce-eadc1985c4b8
[flink-runner-job-server] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Created BLOB cache storage directory /tmp/blobStore-dada382b-72d7-4fd9-8174-3327f9a28631
[flink-runner-job-server] INFO org.apache.flink.runtime.blob.TransientBlobCache - Created BLOB cache storage directory /tmp/blobStore-afe9fa3a-0693-4df8-b7cd-c7228882e3bd
[flink-runner-job-server] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting 1 TaskManger(s)
[flink-runner-job-server] INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Starting TaskManager with ResourceID: 10218d34-4e13-4e39-81b0-a8d04c5dd63a
[flink-runner-job-server] INFO org.apache.flink.runtime.taskexecutor.TaskManagerServices - Temporary file directory '/tmp': total 484 GB, usable 291 GB (60.12% usable)
Could not stop org.gradle.internal.actor.internal.DefaultActorFactory$NonBlockingActor@324c93ac.
org.gradle.internal.dispatch.DispatchException: Could not dispatch message [MethodInvocation method: stop()].
at org.gradle.internal.dispatch.ExceptionTrackingFailureHandler.dispatchFailed(ExceptionTrackingFailureHandler.java:34)
at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:31)
at org.gradle.internal.dispatch.AsyncDispatch.dispatchMessages(AsyncDispatch.java:133)
at org.gradle.internal.dispatch.AsyncDispatch.access$000(AsyncDispatch.java:34)
at org.gradle.internal.dispatch.AsyncDispatch$1.run(AsyncDispatch.java:73)
at org.gradle.internal.operations.CurrentBuildOperationPreservingRunnable.run(CurrentBuildOperationPreservingRunnable.java:42)
at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:63)
at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:46)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:55)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.gradle.process.internal.ExecException: Process 'Gradle Test Executor 1' finished with non-zero exit value 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
at org.gradle.api.internal.tasks.testing.worker.ForkingTestClassProcessor.stop(ForkingTestClassProcessor.java:155)
at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.endBatch(RestartEveryNTestClassProcessor.java:77)
at org.gradle.api.internal.tasks.testing.processors.RestartEveryNTestClassProcessor.stop(RestartEveryNTestClassProcessor.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at org.gradle.internal.dispatch.FailureHandlingDispatch.dispatch(FailureHandlingDispatch.java:29)
... 10 more
org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests > testMultiOutputParDoWithSideInputsIsCumulative SKIPPED
org.apache.beam.sdk.testing.PAssertTest > testGlobalWindowContainsInAnyOrder SKIPPED
63 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 8,5,main]) completed. Took 23 mins 40.4 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 28m 32s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/ayv7simkxrmiw
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 #130
Posted by Apache Jenkins Server <je...@builds.apache.org>.
See <https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/130/display/redirect>
------------------------------------------
[...truncated 186.33 MB...]
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (16/16) (488d13e20ccf91d025a280fcb18c5bc9).
[DataSink (DiscardingOutput) (16/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (16/16) (488d13e20ccf91d025a280fcb18c5bc9) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) cc5477ec244134bf26467bace3338550.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (c64ebad073bca25803161ca7af72f906) 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) (c64ebad073bca25803161ca7af72f906) [DEPLOYING]
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (2/16) (c64ebad073bca25803161ca7af72f906) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (4/16) (cc5477ec244134bf26467bace3338550) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (2/16) (c64ebad073bca25803161ca7af72f906) [DEPLOYING].
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16) (fa1ab8d840de49bf9bfde103a5dc7e08) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16) (fa1ab8d840de49bf9bfde103a5dc7e08).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (4/16).
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (c64ebad073bca25803161ca7af72f906) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-9] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16) (fa1ab8d840de49bf9bfde103a5dc7e08) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (c64ebad073bca25803161ca7af72f906) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) switched from SCHEDULED to DEPLOYING.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (2/16) (c64ebad073bca25803161ca7af72f906) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (2/16) (c64ebad073bca25803161ca7af72f906).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 516c5d600b5a8368a638187cb4d694ed.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (11/16) (attempt #0) to localhost
[DataSink (DiscardingOutput) (2/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (2/16) (c64ebad073bca25803161ca7af72f906) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 6cbe21febd5b2c9983995d03043c67df.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2) [DEPLOYING]
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (8/16) (516c5d600b5a8368a638187cb4d694ed) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (12/16) (51f8bc71864ece583e8ed2a86fb31c1e) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (12/16) (51f8bc71864ece583e8ed2a86fb31c1e).
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 7590213b358620b1cba08513e626fa58.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (12/16) (51f8bc71864ece583e8ed2a86fb31c1e) [FINISHED]
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (15/16) (6cbe21febd5b2c9983995d03043c67df) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 7ed603fd8650241abd0a45529492e8f6.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16) (3cd0e18c960fdfc28da5682f20f90458) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16) (3cd0e18c960fdfc28da5682f20f90458).
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) cd55f7bf2538f1f5827368ba6da6116f.
[jobmanager-future-thread-12] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) switched from CREATED to SCHEDULED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16) (3cd0e18c960fdfc28da5682f20f90458) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) de44891489f32d20ea8640025bccbdad.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (14/16) (7590213b358620b1cba08513e626fa58) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 488d13e20ccf91d025a280fcb18c5bc9.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16) (6d4562868948dec03b6a5e68aaf50b51) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2).
[jobmanager-future-thread-14] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) fa1ab8d840de49bf9bfde103a5dc7e08.
[DataSink (DiscardingOutput) (4/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2) [FINISHED]
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16) (6d4562868948dec03b6a5e68aaf50b51).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (12/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (7/16) (7ed603fd8650241abd0a45529492e8f6) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (13/16) (attempt #0) to localhost
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16) (6d4562868948dec03b6a5e68aaf50b51) [FINISHED]
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (10/16) (cd55f7bf2538f1f5827368ba6da6116f) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (9/16) (dbe3cdcd835f632c22fadce69fc9c11b) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (9/16) (dbe3cdcd835f632c22fadce69fc9c11b).
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (5/16) (de44891489f32d20ea8640025bccbdad) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (9/16) (dbe3cdcd835f632c22fadce69fc9c11b) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (11/16).
[jobmanager-future-thread-11] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (16/16) (488d13e20ccf91d025a280fcb18c5bc9) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (3/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (11/16) (fa1ab8d840de49bf9bfde103a5dc7e08) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) c64ebad073bca25803161ca7af72f906.
[jobmanager-future-thread-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) 51f8bc71864ece583e8ed2a86fb31c1e.
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) switched from CREATED to DEPLOYING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) 3cd0e18c960fdfc28da5682f20f90458.
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) [DEPLOYING]
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (2/16) (c64ebad073bca25803161ca7af72f906) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 5af6a7d1d1fd06653413101d8e1b0fb2.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (9/16) (attempt #0) to localhost
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (12/16) (51f8bc71864ece583e8ed2a86fb31c1e) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16) (4658823c2d52d3de919f2c463a6f59d8) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16) (4658823c2d52d3de919f2c463a6f59d8).
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) [DEPLOYING].
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16) (4658823c2d52d3de919f2c463a6f59d8) [FINISHED]
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (13/16) (3cd0e18c960fdfc28da5682f20f90458) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (4/16) (5af6a7d1d1fd06653413101d8e1b0fb2) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (12/16).
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0).
[DataSink (DiscardingOutput) (11/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) [FINISHED]
[jobmanager-future-thread-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) 6d4562868948dec03b6a5e68aaf50b51.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (1/16) (attempt #0) to localhost
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) 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) (81c00438943b9156d54d80edf6c73c9c) [DEPLOYING]
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (3/16) (6d4562868948dec03b6a5e68aaf50b51) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) [DEPLOYING].
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (13/16).
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) dbe3cdcd835f632c22fadce69fc9c11b.
[DataSink (DiscardingOutput) (12/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) [FINISHED]
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) 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) (e88ec6a2a18d6d75abe44b047a5d007f) [DEPLOYING]
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (9/16) (dbe3cdcd835f632c22fadce69fc9c11b) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) [DEPLOYING].
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (3/16).
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f).
[DataSink (DiscardingOutput) (13/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) [FINISHED]
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) 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) (787a5008ff8573bfd2e3c229d5323c38) [DEPLOYING]
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) [DEPLOYING].
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (9/16).
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) 4658823c2d52d3de919f2c463a6f59d8.
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) switched from CREATED to DEPLOYING.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38).
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) [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) e1318c3f022fb9335e2d4b5ceeb24ab0.
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) [DEPLOYING].
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16) (cd0815fd4953abede5047dfd3958e15b) switched from RUNNING to FINISHED.
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16) (cd0815fd4953abede5047dfd3958e15b).
[DataSink (DiscardingOutput) (3/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) [FINISHED]
[MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16) (cd0815fd4953abede5047dfd3958e15b) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (1/16) (4658823c2d52d3de919f2c463a6f59d8) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) [DEPLOYING].
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) switched from DEPLOYING to RUNNING.
[jobmanager-future-thread-8] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) switched from CREATED to SCHEDULED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (11/16) (e1318c3f022fb9335e2d4b5ceeb24ab0) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e).
[DataSink (DiscardingOutput) (9/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) [FINISHED]
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (1/16).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) switched from SCHEDULED to DEPLOYING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink (DiscardingOutput) (6/16) (attempt #0) to localhost
[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) 81c00438943b9156d54d80edf6c73c9c.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) 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) (98df9134b6858f20d7d97b05c60af2b3) [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) e88ec6a2a18d6d75abe44b047a5d007f.
[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) 787a5008ff8573bfd2e3c229d5323c38.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (12/16) (81c00438943b9156d54d80edf6c73c9c) 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 MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) cd0815fd4953abede5047dfd3958e15b.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (13/16) (e88ec6a2a18d6d75abe44b047a5d007f) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (3/16) (787a5008ff8573bfd2e3c229d5323c38) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) [DEPLOYING].
[flink-akka.actor.default-dispatcher-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task DataSink (DiscardingOutput) (6/16).
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MapPartition (MapPartition at [2]PAssert$90/{RunChecks, VerifyAssertions}) (6/16) (cd0815fd4953abede5047dfd3958e15b) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) 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) 00e9dc5cf885b86ba5fe19f765065b7e.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) 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) (3163eae7510518ad4d63fd8fa0a53bf7) [DEPLOYING]
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (9/16) (00e9dc5cf885b86ba5fe19f765065b7e) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3).
[DataSink (DiscardingOutput) (1/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) [FINISHED]
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) [DEPLOYING].
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 98df9134b6858f20d7d97b05c60af2b3.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) switched from DEPLOYING to RUNNING.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) switched from DEPLOYING to RUNNING.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) switched from RUNNING to FINISHED.
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7).
[DataSink (DiscardingOutput) (6/16)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) [FINISHED]
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (1/16) (98df9134b6858f20d7d97b05c60af2b3) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FINISHED to JobManager for task DataSink (DiscardingOutput) 3163eae7510518ad4d63fd8fa0a53bf7.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - DataSink (DiscardingOutput) (6/16) (3163eae7510518ad4d63fd8fa0a53bf7) switched from RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job countingsourcetest0testboundedsourcesplits-jenkins-1209062522-c6e69234 (fe67df4544f47ac0ee163a20a1401bf6) switched from state RUNNING to FINISHED.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job fe67df4544f47ac0ee163a20a1401bf6 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-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job countingsourcetest0testboundedsourcesplits-jenkins-1209062522-c6e69234(fe67df4544f47ac0ee163a20a1401bf6).
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher60cee46a-a3fe-4b80-9451-6efd3cac313a.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher60cee46a-a3fe-4b80-9451-6efd3cac313a.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Closing the SlotManager.
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Suspending the SlotManager.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection ae144ff7dae8c85b4fc7c5a18ab47f3c: JobManager is shutting down..
[flink-akka.actor.default-dispatcher-7] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool.
[flink-akka.actor.default-dispatcher-7] 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-7] 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 fe67df4544f47ac0ee163a20a1401bf6 with leader id 9f4b3213f2c612e8705b8417c89f46cf lost leadership.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /tmp/flink-io-303a377a-aa75-4c7c-8532-8f3e5ddbc3ef
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Shutting down the network environment and its components.
[ForkJoinPool.commonPool-worker-11] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory /tmp/flink-web-ui
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.StackTraceSampleCoordinator - Shutting down stack trace sample coordinator.
[flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher60cee46a-a3fe-4b80-9451-6efd3cac313a.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_102.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
[flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:41983
[flink-akka.actor.default-dispatcher-2] 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 15064 msecs
[flink-runner-job-server] INFO org.apache.beam.runners.fnexecution.artifact.BeamFileSystemArtifactRetrievalService - Manifest at /tmp/beam-artifact-staging/countingsourcetest0testboundedsourcesplits-jenkins-1209062522-c6e69234_7d79c233-7bef-4721-a545-ad6fc3571e43/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-1209062522-c6e69234_7d79c233-7bef-4721-a545-ad6fc3571e43/
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - JobServer stopped on localhost:34899
[Test worker] INFO org.apache.beam.runners.flink.FlinkJobServerDriver - ArtifactStagingServer stopped on localhost:37259
Gradle Test Executor 2 finished executing tests.
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch
org.apache.beam.sdk.testing.PAssertTest > testWindowedSerializablePredicate SKIPPED
> Task :beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch FAILED
:beam-runners-flink_2.11-job-server:validatesPortableRunnerBatch (Thread[Task worker for ':' Thread 7,5,main]) completed. Took 20 mins 54.711 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 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 25m 26s
75 actionable tasks: 70 executed, 4 from cache, 1 up-to-date
Publishing build scan...
https://gradle.com/s/ia2plwwmtnt6u
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