首页 笔记 图片 查字 
所属分类:Flink
浏览:42
内容:

由jobmanager触发、管理检查点,保存由taskmanager处理

恢复检查点(Checkpoints)/保存点(Savepoints)命令:

# 恢复savepoint
flink run -s /tmp/state.backend/s2/savepoint-11c640-2cdf6befdc8e -c org.test.HelloWorld ./test-app.jar

# 恢复checkpoint
flink run -s /tmp/state.backend/1dsbt90a3d2sdd1b94sdgc88f7uyk49law/chk-990 -c org.test.HelloWorld ./test-app.jar