Flink这个启动状态恢复的机制是什么样的?[阿里云实时计算 Flink版]

Flink这个启动状态恢复的机制是什么样的?请教大佬们一个问题,我使用checkpoint做状态恢复,任务里设置了configuration.set(SavepointConfigOptions.SAVEPOINT_PATH, file.getPath(),并且用了自己写的一个客户端以perjob模式提交到yarn上,发现我的状态没有恢复,isRestored是false
但是使用application模式提交的话是能正常读取我的状态的,后续我又测试了使用官方的flink-client提交,发现都可以正常读取状态。我debug源码发现JobGraph里有savepointRestoreSettings相关的配置,是在yarn-per-job模式提交代码必须有这个配置项吗?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====