Flink这个问题该怎么解决?

Flink这个问题该怎么解决?
org.apache.flink.runtime.taskexecutor.exceptions.TaskSubmissionException: Could not re-integrate offloaded TaskDeploymentDescriptor data.
at org.apache.flink.runtime.taskexecutor.TaskExecutor.submitTask(TaskExecutor.java:656)
at sun.reflect.GeneratedMethodAccessor81.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.lambda$handleRpcInvocation$1(AkkaRpcActor.java:309)
at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:307)
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222)
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at akka.actor.Actor.aroundReceive(Actor.scala:537)
at akka.actor.Actor.aroundReceive$(Actor.scala:535)
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
at akka.actor.ActorCell.invoke(ActorCell.scala:547)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
Caused by: java.io.IOException: Failed to fetch BLOB b745be6beef8d8a63f73d409fb90cc55/p-fc83ff34fac2f0a0373b3d918db75c1db9bfb249-64cd89ba927e7bc4ed4c9fe987a6227f from 192.168.8.76/192.168.8.76:45978 and store it under /tmp/tm_192.168.8.77:40402-273bff/blobStorage/incoming/temp-00047976
at org.apache.flink.runtime.blob.BlobClient.downloadFromBlobServer(BlobClient.java:168)
at org.apache.flink.runtime.blob.AbstractBlobCache.getFileInternal(AbstractBlobCache.java:177)
at org.apache.flink.runtime.blob.PermanentBlobCache.getFile(PermanentBlobCache.java:269)
at org.apache.flink.runtime.deployment.TaskDeploymentDescriptor.loadBigData(TaskDeploymentDescriptor.java:267)
at org.apache.flink.runtime.taskexecutor.TaskExecutor.submitTask(TaskExecutor.java:654)
... 28 more
Caused by: java.io.IOException: GET operation failed: Server side error: /tmp/jm_37cac9447f77cd1b7f6eba42312eeea9/blobStorage/incoming/temp-00429873
at org.apache.flink.runtime.blob.BlobClient.getInternal(BlobClient.java:231)
at org.apache.flink.runtime.blob.BlobClient.downloadFromBlobServer(BlobClient.java:139)
... 32 more
Caused by: java.io.IOException: Server side error: /tmp/jm_37cac9447f77cd1b7f6eba42312eeea9/blobStorage/incoming/temp-00429873
at org.apache.flink.runtime.blob.BlobClient.receiveAndCheckGetResponse(BlobClient.java:277)
at org.apache.flink.runtime.blob.BlobClient.getInternal(BlobClient.java:226)
... 33 more
Caused by: java.nio.file.NoSuchFileException: /tmp/jm_37cac9447f77cd1b7f6eba42312eeea9/blobStorage/incoming/temp-00429873
at sun.nio.fs.UnixException.translateToIOException(UnixException.java:86)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)
at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)
at sun.nio.fs.UnixCopyFile.move(UnixCopyFile.java:409)
at sun.nio.fs.UnixFileSystemProvider.move(UnixFileSystemProvider.java:262)
at java.nio.file.Files.move(Files.java:1395)
at org.apache.flink.runtime.blob.BlobUtils.lambda$moveTempFileToStore$0(BlobUtils.java:422)
at org.apache.flink.runtime.blob.BlobUtils.internalMoveTempFileToStore(BlobUtils.java:446)
at org.apache.flink.runtime.blob.BlobUtils.moveTempFileToStore(BlobUtils.java:415)
at org.apache.flink.runtime.blob.BlobServer.getFileInternal(BlobServer.java:533)
at org.apache.flink.runtime.blob.BlobServerConnection.get(BlobServerConnection.java:221)
at org.apache.flink.runtime.blob.BlobServerConnection.run(BlobServerConnection.java:113)

展开
收起
嘟嘟嘟嘟嘟嘟 2024-01-24 07:56:41 140 分享 版权
0 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理