flink从checkpoint中恢复任务失败? 5C

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

为什么不是

图片说明

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

2个回答

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

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问
相关内容推荐