tim.yuan created FLINK-25467:
--------------------------------

             Summary: Job failed during initialization of JobManager
                 Key: FLINK-25467
                 URL: https://issues.apache.org/jira/browse/FLINK-25467
             Project: Flink
          Issue Type: Bug
          Components: API / Core
    Affects Versions: 1.14.2
            Reporter: tim.yuan


HA   deploy

slave  open runing task fail !

 

2021-12-28 19:13:03,992 WARN  
org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler [] - The 
connection was unexpectedly closed by the client.
2021-12-28 19:13:44,172 ERROR 
org.apache.flink.runtime.rest.handler.job.JobDetailsHandler  [] - 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.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.runtime.rest.handler.legacy.DefaultExecutionGraphCache.getExecutionGraphInfo(DefaultExecutionGraphCache.java:67)
 ~[flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.handleRequest(AbstractExecutionGraphHandler.java:81)
 ~[flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.runtime.rest.handler.AbstractRestHandler.respondToRequest(AbstractRestHandler.java:83)
 ~[flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.runtime.rest.handler.AbstractHandler.respondAsLeader(AbstractHandler.java:195)
 ~[flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.lambda$channelRead0$0(LeaderRetrievalHandler.java:83)
 ~[flink-dist_2.12-1.14.0.jar:1.14.0]
    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.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:80)
 [flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.runtime.rest.handler.LeaderRetrievalHandler.channelRead0(LeaderRetrievalHandler.java:49)
 [flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)
 [flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
 [flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
 [flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
 [flink-dist_2.12-1.14.0.jar:1.14.0]
    at 
org.apache.flink.runtime.rest.handler.router.RouterHandler.routed(RouterHandler.java:115)
 [flink-dist_2.12-1.14.0.jar:1.14.0]



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to