长时间运行的flink任务会有以下报错

[jiafu <53...@qq.com>]

flink任务运行时会有以下的报错，用的是flink-1.8.1
org.apache.flink.runtime.executiongraph.ExecutionGraphException: Trying to eagerly schedule a task whose inputs are not ready (result type: PIPELINED_BOUNDED, partition consumable: false, producer state: SCHEDULED, producer slot: null). 	at org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor.fromEdges(InputChannelDeploymentDescriptor.java:145) 	at org.apache.flink.runtime.executiongraph.ExecutionVertex.createDeploymentDescriptor(ExecutionVertex.java:840) 	at org.apache.flink.runtime.executiongraph.Execution.deploy(Execution.java:621) 	at org.apache.flink.util.function.ThrowingRunnable.lambda$unchecked$0(ThrowingRunnable.java:50) 	at java.util.concurrent.CompletableFuture.uniRun(CompletableFuture.java:705) 	at java.util.concurrent.CompletableFuture.uniRunStage(CompletableFuture.java:717) 	at java.util.concurrent.CompletableFuture.thenRun(CompletableFuture.java:2010) 	at org.apache.flink.runtime.executiongraph.Execution.scheduleForExecution(Execution.java:436) 	at org.apache.flink.runtime.executiongraph.ExecutionVertex.scheduleForExecution(ExecutionVertex.java:637) 	at org.apache.flink.runtime.executiongraph.failover.FailoverRegion.restart(FailoverRegion.java:229) 	at org.apache.flink.runtime.executiongraph.failover.FailoverRegion.reset(FailoverRegion.java:186) 	at org.apache.flink.runtime.executiongraph.failover.FailoverRegion.allVerticesInTerminalState(FailoverRegion.java:96) 	at org.apache.flink.runtime.executiongraph.failover.FailoverRegion.lambda$cancel$0(FailoverRegion.java:146) 	at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:656) 	at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) 	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) 	at org.apache.flink.runtime.concurrent.FutureUtils$WaitingConjunctFuture.handleCompletedFuture(FutureUtils.java:633) 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) 	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) 	at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) 	at org.apache.flink.runtime.executiongraph.Execution.lambda$releaseAssignedResource$11(Execution.java:1350) 	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) 	at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:778) 	at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2140) 	at org.apache.flink.runtime.executiongraph.Execution.releaseAssignedResource(Execution.java:1345) 	at org.apache.flink.runtime.executiongraph.Execution.finishCancellation(Execution.java:1115) 	at org.apache.flink.runtime.executiongraph.Execution.completeCancelling(Execution.java:1094) 	at org.apache.flink.runtime.executiongraph.ExecutionGraph.updateState(ExecutionGraph.java:1628) 	at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:517) 	at sun.reflect.GeneratedMethodAccessor63.invoke(Unknown Source) 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 	at java.lang.reflect.Method.invoke(Method.java:498) 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:274) 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:189) 	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74) 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:147) 	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.onReceive(FencedAkkaRpcActor.java:40) 	at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165) 	at akka.actor.Actor$class.aroundReceive(Actor.scala:502) 	at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95) 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526) 	at akka.actor.ActorCell.invoke(ActorCell.scala:495) 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) 	at akka.dispatch.Mailbox.run(Mailbox.scala:224) 	at akka.dispatch.Mailbox.exec(Mailbox.scala:234) 	at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) 	at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) 	at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) 	at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

回复: 长时间运行的flink任务会有以下报错

["sjlsumaitong@163.com" <sj...@163.com>]

同问，大佬看到帮下忙！



sjlsumaitong@163.com
 
发件人： jiafu
发送时间： 2020-07-20 19:31
收件人： user-zh
主题： 长时间运行的flink任务会有以下报错
flink任务运行时会有以下的报错，用的是flink-1.8.1
org.apache.flink.runtime.executiongraph.ExecutionGraphException: Trying to eagerly schedule a task whose inputs are not ready (result type: PIPELINED_BOUNDED, partition consumable: false, producer state: SCHEDULED, producer slot: null). at org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor.fromEdges(InputChannelDeploymentDescriptor.java:145) at org.apache.flink.runtime.executiongraph.ExecutionVertex.createDeploymentDescriptor(ExecutionVertex.java:840) at org.apache.flink.runtime.executiongraph.Execution.deploy(Execution.java:621) at org.apache.flink.util.function.ThrowingRunnable.lambda$unchecked$0(ThrowingRunnable.java:50) at java.util.concurrent.CompletableFuture.uniRun(CompletableFuture.java:705) at java.util.concurrent.CompletableFuture.uniRunStage(CompletableFuture.java:717) at java.util.concurrent.CompletableFuture.thenRun(CompletableFuture.java:2010) at org.apache.flink.runtime.executiongraph.Execution.scheduleForExecution(Execution.java:436) at org.apache.flink.runtime.executiongraph.ExecutionVertex.scheduleForExecution(ExecutionVertex.java:637) at org.apache.flink.runtime.executiongraph.failover.FailoverRegion.restart(FailoverRegion.java:229) at org.apache.flink.runtime.executiongraph.failover.FailoverRegion.reset(FailoverRegion.java:186) at org.apache.flink.runtime.executiongraph.failover.FailoverRegion.allVerticesInTerminalState(FailoverRegion.java:96) at org.apache.flink.runtime.executiongraph.failover.FailoverRegion.lambda$cancel$0(FailoverRegion.java:146) at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:656) at java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632) at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) at org.apache.flink.runtime.concurrent.FutureUtils$WaitingConjunctFuture.handleCompletedFuture(FutureUtils.java:633) at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) at org.apache.flink.runtime.executiongraph.Execution.lambda$releaseAssignedResource$11(Execution.java:1350) at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:778) at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2140) at org.apache.flink.runtime.executiongraph.Execution.releaseAssignedResource(Execution.java:1345) at org.apache.flink.runtime.executiongraph.Execution.finishCancellation(Execution.java:1115) at org.apache.flink.runtime.executiongraph.Execution.completeCancelling(Execution.java:1094) at org.apache.flink.runtime.executiongraph.ExecutionGraph.updateState(ExecutionGraph.java:1628) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:517) at sun.reflect.GeneratedMethodAccessor63.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:274) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:189) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.onReceive(AkkaRpcActor.java:147) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.onReceive(FencedAkkaRpcActor.java:40) at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:165) at akka.actor.Actor$class.aroundReceive(Actor.scala:502) at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526) at akka.actor.ActorCell.invoke(ActorCell.scala:495) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257) at akka.dispatch.Mailbox.run(Mailbox.scala:224) at akka.dispatch.Mailbox.exec(Mailbox.scala:234) at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)