[ https://issues.apache.org/jira/browse/FLINK-12927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robert Metzger closed FLINK-12927. ---------------------------------- Fix Version/s: (was: 1.11.0) Resolution: Duplicate I believe this has been fixed inĀ FLINK-12863. Closing ticket. > YARNSessionCapacitySchedulerITCase failed due to non prohibited exception > ------------------------------------------------------------------------- > > Key: FLINK-12927 > URL: https://issues.apache.org/jira/browse/FLINK-12927 > Project: Flink > Issue Type: Bug > Components: Deployment / YARN, Tests > Affects Versions: 1.9.0 > Reporter: Yun Tang > Assignee: Robert Metzger > Priority: Critical > Labels: test-stability > > YARNSessionCapacitySchedulerITCase fails due to non prohibited exception. > [https://api.travis-ci.org/v3/job/548491542/log.txt] > {code:java} > 2019-06-21 08:22:27,313 INFO > org.apache.flink.runtime.executiongraph.ExecutionGraph - Reduce > (SUM(1), at main(WordCount.java:79) (2/2) (a1708bb0544633b4e57e8bb84a1a48f3) > switched from RUNNING to FAILED. > org.apache.flink.util.FlinkException: 0283de7d26d7fb08895955bfb75db496 is no > longer allocated by job 8f8dced4fb89f8e5cb05d9286683ecaf. > org.apache.flink.util.FlinkException: 0283de7d26d7fb08895955bfb75db496 is no > longer allocated by job 8f8dced4fb89f8e5cb05d9286683ecaf. > at > org.apache.flink.runtime.taskexecutor.TaskExecutor.freeNoLongerUsedSlots(TaskExecutor.java:1475) > at > org.apache.flink.runtime.taskexecutor.TaskExecutor.syncSlotsWithSnapshotFromJobMaster(TaskExecutor.java:1436) > at > org.apache.flink.runtime.taskexecutor.TaskExecutor.access$3200(TaskExecutor.java:141) > at > org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$reportPayload$1(TaskExecutor.java:1691) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:397) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:190) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152) > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) > at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) > at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > at akka.actor.Actor$class.aroundReceive(Actor.scala:517) > at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) > at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) > at akka.actor.ActorCell.invoke(ActorCell.scala:561) > at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) > at akka.dispatch.Mailbox.run(Mailbox.scala:225) > at akka.dispatch.Mailbox.exec(Mailbox.scala:235) > at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > 2019-06-21 08:22:27,333 INFO > org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Flink > Java Job at Fri Jun 21 08:22:16 UTC 2019 (8f8dced4fb89f8e5cb05d9286683ecaf) > switched from state RUNNING to FAILING. > org.apache.flink.util.FlinkException: 0283de7d26d7fb08895955bfb75db496 is no > longer allocated by job 8f8dced4fb89f8e5cb05d9286683ecaf. > at > org.apache.flink.runtime.taskexecutor.TaskExecutor.freeNoLongerUsedSlots(TaskExecutor.java:1475) > at > org.apache.flink.runtime.taskexecutor.TaskExecutor.syncSlotsWithSnapshotFromJobMaster(TaskExecutor.java:1436) > at > org.apache.flink.runtime.taskexecutor.TaskExecutor.access$3200(TaskExecutor.java:141) > at > org.apache.flink.runtime.taskexecutor.TaskExecutor$JobManagerHeartbeatListener.lambda$reportPayload$1(TaskExecutor.java:1691) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:397) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:190) > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152) > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21){code} -- This message was sent by Atlassian Jira (v8.3.4#803005)