感觉还有其它 root cause，可以看下还有其它日志不？
Best, Hailong At 2020-11-18 15:52:57, "赵一旦" <hinobl...@gmail.com> wrote: >2020-11-18 16:51:37 >org.apache.flink.runtime.io.network.partition.PartitionNotFoundException: >Partition b225fa9143dfa179d3a3bd223165d5c5#3@3fee4d51f5a43001ef743f3f15e4cfb2 >not found. > at org.apache.flink.runtime.io.network.partition.consumer. >RemoteInputChannel.failPartitionRequest(RemoteInputChannel.java:267) > at org.apache.flink.runtime.io.network.partition.consumer. >RemoteInputChannel.retriggerSubpartitionRequest(RemoteInputChannel.java:166) > at org.apache.flink.runtime.io.network.partition.consumer. >SingleInputGate.retriggerPartitionRequest(SingleInputGate.java:521) > at org.apache.flink.runtime.io.network.partition.consumer. >SingleInputGate.lambda$triggerPartitionStateCheck$1(SingleInputGate.java:765 >) > at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture >.java:670) > at java.util.concurrent.CompletableFuture$UniAccept.tryFire( >CompletableFuture.java:646) > at java.util.concurrent.CompletableFuture$Completion.run( >CompletableFuture.java:456) > at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) > at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec( >ForkJoinExecutorConfigurator.scala:44) > 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) > > >请问这是什么问题呢？
