是一个per模式运行的测试job,检查下 JobManager是正常的
基于flink1.4.0, flink集群开启了kerberos flink-conf.yaml中已经配置过 targetDirectory目录 ------------------------------------------------------------ The program finished with the following exception: org.apache.flink.util.FlinkException: Could not connect to the leading JobManager. Please check that the JobManager is running. at org.apache.flink.client.program.ClusterClient.getJobManagerGateway(ClusterClient.java:861) at org.apache.flink.client.program.ClusterClient.listJobs(ClusterClient.java:699) at org.apache.flink.client.CliFrontend.list(CliFrontend.java:439) at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1082) at org.apache.flink.client.CliFrontend$1.call(CliFrontend.java:1127) at org.apache.flink.client.CliFrontend$1.call(CliFrontend.java:1124) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1781) at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1124) Caused by: org.apache.flink.runtime.leaderretrieval.LeaderRetrievalException: Could not retrieve the leader gateway. at org.apache.flink.runtime.util.LeaderRetrievalUtils.retrieveLeaderGateway(LeaderRetrievalUtils.java:79) at org.apache.flink.client.program.ClusterClient.getJobManagerGateway(ClusterClient.java:856) ... 10 more Caused by: java.util.concurrent.TimeoutException: Futures timed out after [10000 milliseconds] at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:223) at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:227) at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:190) at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53) at scala.concurrent.Await$.result(package.scala:190) at scala.concurrent.Await.result(package.scala) at org.apache.flink.runtime.util.LeaderRetrievalUtils.retrieveLeaderGateway(LeaderRetrievalUtils.java:77) ... 11 more |
解决了 At 2019-12-04 09:54:17, "guoshuai" <[hidden email]> wrote: >是一个per模式运行的测试job,检查下 JobManager是正常的 >基于flink1.4.0, flink集群开启了kerberos >flink-conf.yaml中已经配置过 targetDirectory目录 > >------------------------------------------------------------ > The program finished with the following exception: > >org.apache.flink.util.FlinkException: Could not connect to the leading JobManager. Please check that the JobManager is running. > at org.apache.flink.client.program.ClusterClient.getJobManagerGateway(ClusterClient.java:861) > at org.apache.flink.client.program.ClusterClient.listJobs(ClusterClient.java:699) > at org.apache.flink.client.CliFrontend.list(CliFrontend.java:439) > at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1082) > at org.apache.flink.client.CliFrontend$1.call(CliFrontend.java:1127) > at org.apache.flink.client.CliFrontend$1.call(CliFrontend.java:1124) > at java.security.AccessController.doPrivileged(Native Method) > at javax.security.auth.Subject.doAs(Subject.java:422) > at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1781) > at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) > at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1124) >Caused by: org.apache.flink.runtime.leaderretrieval.LeaderRetrievalException: Could not retrieve the leader gateway. > at org.apache.flink.runtime.util.LeaderRetrievalUtils.retrieveLeaderGateway(LeaderRetrievalUtils.java:79) > at org.apache.flink.client.program.ClusterClient.getJobManagerGateway(ClusterClient.java:856) > ... 10 more >Caused by: java.util.concurrent.TimeoutException: Futures timed out after [10000 milliseconds] > at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:223) > at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:227) > at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:190) > at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53) > at scala.concurrent.Await$.result(package.scala:190) > at scala.concurrent.Await.result(package.scala) > at org.apache.flink.runtime.util.LeaderRetrievalUtils.retrieveLeaderGateway(LeaderRetrievalUtils.java:77) > ... 11 more > |
Free forum by Nabble | Edit this page |