Re:bin/flink savepoint jobId 出错

解决了 At 2019-12-04 09:54:17, "guoshuai" wrote: >是一个per模式运行的测试job，检查下 JobManager是正常的 >基于flink1.4.0, flink集群开启了kerberos >flink-conf.yaml中已经配置过 targetDirectory目录 > > > The program finished

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 Job

Re:回复: 回复: flink on yarn 的 kerberos 认证问题

igured to only allow secure connections” > > > > >-邮件原件- >发件人: user-zh-return-1559-wxchunjhyy=163@flink.apache.org > 代表 guoshuai >发送时间: Wednesday, November 27, 2019 2:26 PM >收件人: user-zh@flink.apache.org >主题: Re:回复: flink on yarn 的 kerbe

Re:回复: flink on yarn 的 kerberos 认证问题

ons” > > > >-----邮件原件----- >发件人: user-zh-return-1557-wxchunjhyy=163@flink.apache.org > 代表 guoshuai >发送时间: Wednesday, November 27, 2019 1:31 PM >收件人: user-zh@flink.apache.org >主题: Re:flink on yarn 的 kerberos 认证问题 > >kerberos用户的krb5.conf ,user.keytab文件是否在程序运行时加载到了,我

Re:flink on yarn 的 kerberos 认证问题

kerberos用户的krb5.conf ,user.keytab文件是否在程序运行时加载到了,我之前遇到的kerberos问题是flink读kafka获取不到数据,通过yarn-session模式运行,认证阶段是在yarn-session发布完成的. 最后问题出在kafka通信协议,可以看下hbase端的配置,实现不行 也可以解耦hbase跟flink中间加一个kafka 在 2019-11-26 14:50:32，"venn" 写道： >各位大佬： > >请教一个flink 认证的问题： Flink on yarn 运行在不用认证的 Hado