Hi, xinzhuxiansheng 这个异常日志看起来不是根本原因,方便提供下全量 JobManager 日志吗?
> 2022年2月28日 下午7:50,xinzhuxiansheng <xinzhuxiansh...@126.com> 写道: > > 我的环境: > Flink on Native K8s Application mode,并且用S3协议来做HA部署, 部署后,作业正常工作,可Flink UI > 无法正常打开 作业的拓扑图,页面会提示内部错误 > > > jobmanager会提示很多 类似的异常: > 2022-02-28 08:46:21,171 ERROR > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler [] - Unhandled > exception. > java.util.concurrent.CancellationException: null > at > java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2276) > ~[?:1.8.0_312] > at > org.apache.flink.runtime.rest.handler.legacy.DefaultExecutionGraphCache.getExecutionGraphInternal(DefaultExecutionGraphCache.java:98) > ~[flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.legacy.DefaultExecutionGraphCache.getExecutionGraphInfo(DefaultExecutionGraphCache.java:67) > ~[flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.handleRequest(AbstractExecutionGraphHandler.java:81) > ~[flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.AbstractRestHandler.respondToRequest(AbstractRestHandler.java:83) > ~[flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:195) > ~[flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:83) > ~[flink-dist_2.11-1.14.2.jar:1.14.2] > at java.util.Optional.ifPresent(Optional.java:159) [?:1.8.0_312] > at > org.apache.flink.util.OptionalConsumer.ifPresent(OptionalConsumer.java:45) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:80) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:49) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:94) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.handler.router.RouterHandler.channelRead0(RouterHandler.java:55) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:238) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.runtime.rest.FileUploadHandler.channelRead0(FileUploadHandler.java:71) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:436) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:324) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:296) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:251) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > [flink-dist_2.11-1.14.2.jar:1.14.2] > at > org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) > [flink-dist_2.11-1.14.2.jar:1.14.2] > > > 有人知道这是咋回事么 ? > > > | | > xinzhuxiansheng > | > | > xinzhuxiansh...@126.com > | > 签名由网易邮箱大师定制 >