flink从checkpoint中恢复任务失败？

Question

您好，请教一个问题。
我手动执行命令从checkpoint中恢复，但是提示文件不存在。
生成的checkpoint文件如下

为什么不是

我用savepoint恢复就可以成功
状态后端用的是new FsStateBackend("file:///data/flink/checkpoints")

Answer 1

1.安全模式：【开启状态】

$>hdfs dfsadmin -safemode enter //进入

$>hdfs dfsadmin -safemode leave //离开

$>hdfs dfsadmin -safemode get //获取当前安全模式状态

$>hdfs dfsadmin -safemode wait //等待

2.保存名字空间

$>hdfs dfsadmin -saveNamespace

3.关闭安全模式

$>hdfs dfsadmin -safemode leave //离开

rolledits(滚动日志)

---

$>hdfs dfsadmin -rollEdits