[ https://issues.apache.org/jira/browse/FLINK-25812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17484725#comment-17484725 ]
None none commented on FLINK-25812: ----------------------------------- The UI looks like this: !Screen Shot 2022-01-31 at 9.55.26 AM.png! > Show Plan in Ui doesn't show. > ----------------------------- > > Key: FLINK-25812 > URL: https://issues.apache.org/jira/browse/FLINK-25812 > Project: Flink > Issue Type: Bug > Components: Runtime / Web Frontend > Affects Versions: 1.14.3 > Reporter: None none > Priority: Major > Attachments: Screen Shot 2022-01-31 at 9.55.26 AM.png > > > Click on any job on the Ui to run it. Click "Show Plan". Show plan ui shows > up but blank. There is also an exception recorded. > > 2022-01-25 21:34:02,243 INFO org.apache.flink.runtime.jobmaster.JobMaster > [] - Registration failure at ResourceManager occurred. > org.apache.flink.util.SerializedThrowable: > org.apache.flink.runtime.rpc.exceptions.RpcConnectionException: Could not > connect to rpc endpoint under address > akka.tcp://flink@xxxxxx-v-job-0001:46025/user/rpc/jobmanager_10. > at > org.apache.flink.runtime.rpc.akka.AkkaRpcService.lambda$resolveActorAddress$11(AkkaRpcService.java:602) > ~[?:?] > at > scala.concurrent.java8.FuturesConvertersImpl$CF$$anon$1.accept(FutureConvertersImpl.scala:59) > ~[?:?] > at > scala.concurrent.java8.FuturesConvertersImpl$CF$$anon$1.accept(FutureConvertersImpl.scala:53) > ~[?:?] > at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) > ~[?:1.8.0_312] > at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750) > ~[?:1.8.0_312] > at > java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456) > ~[?:1.8.0_312] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_312] > Caused by: org.apache.flink.util.SerializedThrowable: Could not connect to > rpc endpoint under address > akka.tcp://flink@xxxxxx-v-job-0001:46025/user/rpc/jobmanager_10. > ... 7 more > Caused by: org.apache.flink.util.SerializedThrowable: Actor not found for: > ActorSelection[Anchor(akka://flink/), Path(/user/rpc/jobmanager_10)] > at > akka.actor.ActorSelection.$anonfun$resolveOne$1(ActorSelection.scala:74) > ~[?:?] > at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > at > akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63) > ~[?:?] > at akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:81) > ~[?:?] > at > akka.dispatch.internal.SameThreadExecutionContext$$anon$1.unbatchedExecute(SameThreadExecutionContext.scala:21) > ~[?:?] > at akka.dispatch.BatchingExecutor.execute(BatchingExecutor.scala:130) > ~[?:?] > at akka.dispatch.BatchingExecutor.execute$(BatchingExecutor.scala:124) > ~[?:?] > at > akka.dispatch.internal.SameThreadExecutionContext$$anon$1.execute(SameThreadExecutionContext.scala:20) > ~[?:?] > at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > at > scala.concurrent.impl.Promise$DefaultPromise.dispatchOrAddCallback(Promise.scala:312) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > at > scala.concurrent.impl.Promise$DefaultPromise.onComplete(Promise.scala:303) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > at akka.actor.ActorSelection.resolveOne(ActorSelection.scala:72) ~[?:?] > at akka.actor.ActorSelection.resolveOne(ActorSelection.scala:89) ~[?:?] > at akka.actor.ActorSelection.resolveOne(ActorSelection.scala:130) ~[?:?] > at > org.apache.flink.runtime.rpc.akka.AkkaRpcService.resolveActorAddress(AkkaRpcService.java:596) > ~[?:?] > at > org.apache.flink.runtime.rpc.akka.AkkaRpcService.connectInternal(AkkaRpcService.java:547) > ~[?:?] > at > org.apache.flink.runtime.rpc.akka.AkkaRpcService.connect(AkkaRpcService.java:233) > ~[?:?] > at > org.apache.flink.runtime.resourcemanager.ResourceManager.registerJobManager(ResourceManager.java:367) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > at sun.reflect.GeneratedMethodAccessor70.invoke(Unknown Source) ~[?:?] > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > ~[?:1.8.0_312] > at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_312] > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) > ~[?:?] > at > org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) > ~[?:?] > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) > ~[?:?] > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) > ~[?:?] > at > org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) > ~[?:?] > at > org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) > ~[?:?] > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?] > at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?] > at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) > ~[?:?] > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) > ~[flink-dist_2.12-1.14.3.jar:1.14.3] > 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:580) ~[?:?] > at akka.actor.ActorCell.invoke(ActorCell.scala:548) ~[?:?] > 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) > [?:1.8.0_312] > at > java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) > [?:1.8.0_312] > at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) > [?:1.8.0_312] > at > java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) > [?:1.8.0_312] -- This message was sent by Atlassian Jira (v8.20.1#820001)