Re: 不同的程序在同一时间段报同一个异常

[mq sun]

有些程序挂掉，有些没有

r pp  于2021年6月1日周二 下午2:07写道：

> 你的程序有挂掉么？
>
> mq sun  于2021年5月31日周一 下午7:23写道：
>
> > 大家好：
> >   最近在生产中，不同项目组的两个flink程序在同一时间段都报下面异常
> > ERROR org.apache.flink.runtime.blob.BlobServerConnection  -Error while
> > excuting Blob connection
> > .
> > .
> > .
> >
> >
> org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException
> > :Adjusted frame length exceeds 10485760: 1347375960 -discarded
> >
> >
> >
> 上面的报错信息，刚开始知道其中一个报错的时候，怀疑是状态过大导致的。但是后来又有另外一个程序报同样的错误，现在不确定是什么问题导致，请问大佬这个可能是什么原因
> >
>
>
> --
> Best，
>   pp
>

不同的程序在同一时间段报同一个异常

[mq sun]

大家好：
  最近在生产中，不同项目组的两个flink程序在同一时间段都报下面异常
ERROR org.apache.flink.runtime.blob.BlobServerConnection  -Error while
excuting Blob connection
.
.
.
org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException
:Adjusted frame length exceeds 10485760: 1347375960 -discarded

上面的报错信息，刚开始知道其中一个报错的时候，怀疑是状态过大导致的。但是后来又有另外一个程序报同样的错误，现在不确定是什么问题导致，请问大佬这个可能是什么原因

flink exception cound not retrieve file from transient blob store

[mq sun]

大家好，最近有个程序运行一段时间之后报异常，不知道什么原因引起的，异常如下，由于云桌面环境没法拷贝内容，现在在网上找到一个一样的异常，这个是之前有人发到这个邮件列表的，但是没解决
java.util.concurrent.CompletionException:
org.apache.flink.util.FlinkException: Could not retrieve file from
transient
blob store.
at
org.apache.flink.runtime.rest.handler.taskmanager.AbstractTaskManagerFileHandler.lambda$respondToRequest$0(AbstractTaskManagerFileHandler.java:135)

at
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:656)

at
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:632)

at
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442)

at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163)

at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)

at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:474)

at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:909)

at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.flink.util.FlinkException: Could not retrieve file
from transient blob store.
... 9 more
Caused by: java.io.FileNotFoundException: Local file
/data/yarn/nm/usercache/nlp_realtime/appcache/application_1571815761034_7982/blobStore-ed462e9a-7468-4d9d-8295-c126c84fb5ef/no_job/blob_t-bd919682fabe41b123dbd280e435de85410e3ad5-bd65dcaa30ecab21dfe21ff3c434d906

does not exist and failed to copy from blob store.
at
org.apache.flink.runtime.blob.BlobServer.getFileInternal(BlobServer.java:516)

at
org.apache.flink.runtime.blob.BlobServer.getFileInternal(BlobServer.java:444)

at
org.apache.flink.runtime.blob.BlobServer.getFile(BlobServer.java:369)
at
org.apache.flink.runtime.rest.handler.taskmanager.AbstractTaskManagerFileHandler.lambda$respondToRequest$0(AbstractTaskManagerFileHandler.java:133)

... 8 more

test

[mq sun]