回复:flink checkpoint配置hdfs问题

不要写地址 写nameservice --原始邮件-- 发件人："LJY "

flink checkpoint配置hdfs问题

hi，各位好： hdfs目前是配置了高可用， namenode分别为 nn1(active),nn2(standby) flink-conf.yaml中的配置如下： state.checkpoints.dir: hdfs://nn1的ip:8020/flink/flink-checkpoints/ 然后发布一个job，等checkpoint生成后，把 nn1 namenode 杀掉。 nn2会自动切换成active,nn1无法访问。 job就会不停的restart。 日志显示 failed on connection exception: