开发者社区> 问答> 正文

Flink配置Kerberos认证问题

IMG20190226_092744
由于公司集群 hdfs配置了kerberos认证 最大有效期默认是7天,Flink官网推荐使用这种方式来配置,后面的几个参数都可配置,但是第一个参数这个contexts 不知道怎么配置,有人了解吗 望赐教 谢谢

展开
收起
莱昂007 2019-02-26 09:30:51 10504 0
3 条回答
写回答
取消 提交回答
  • org.apache.flink.util.FlinkException: Failed to retrieve job list.
            at org.apache.flink.client.cli.CliFrontend.listJobs(CliFrontend.java:445)
            at org.apache.flink.client.cli.CliFrontend.lambda$list$0(CliFrontend.java:427)
            at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:956)
            at org.apache.flink.client.cli.CliFrontend.list(CliFrontend.java:424)
            at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1024)
            at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1096)
            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:1875)
            at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
            at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1096)
    Caused by: java.util.concurrent.TimeoutException
            at org.apache.flink.runtime.concurrent.FutureUtils$Timeout.run(FutureUtils.java:998)
            at org.apache.flink.runtime.concurrent.DirectExecutorService.execute(DirectExecutorService.java:211)
            at org.apache.flink.runtime.concurrent.FutureUtils.lambda$orTimeout$14(FutureUtils.java:416)
            at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
            at java.util.concurrent.FutureTask.run(FutureTask.java:266)
            at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
            at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
            at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
            at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
            at java.lang.Thread.run(Thread.java:748)
    
    2020-01-09 16:15:46
    赞同 展开评论 打赏
  • 2019-07-17 23:29:26
    赞同 展开评论 打赏
  • 有详细的报错信息吗?

    2019-07-17 23:29:26
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载