You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by guoshuai <re...@163.com> on 2019/12/04 01:54:17 UTC
bin/flink savepoint jobId 出错
是一个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
Re:bin/flink savepoint jobId 出错
Posted by guoshuai <re...@163.com>.
解决了
At 2019-12-04 09:54:17, "guoshuai" <re...@163.com> 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
>