Hi, 大家好
Flink版本 1.10.0

目前程序的checkpoint使用rocksdb的方式存储在hdfs上,在sink失败的时候能够正常从上一个checkpoint点恢复。
问题是由于升级程序,我使用了命令行
bin/flink stop -p ${hdfsSavepointDir} -d $runningJobId -yid $yarnAppId

将savepoint文件保存,然后再使用保存的savepoint来启动程序
/bin/flink run -d -m yarn-cluster -p ${parallelism} -yjm ${jm} -ytm ${tm} 
$fullJarPath -s $savePointFullPath �Cc xxx

比较无法理解的是,jm和tm日志都显示成功启动,但是无法看到从checkpoint恢复的记录如下图所示:
[cid:[email protected]]

有知道的大佬知道是不是我哪里处理不正常么?

回复