代码中配置状态后端和checkpoint的间隔时间及相关配置
1.flink-conf.yaml中配置Savepoint存储位置
不是必须设置，但是设置后，后面创建指定Job的Savepoint时，可以不用在手动执行命令时指定Savepoint的位置
2.取消任务并将savepoint保存到指定文件夹中
3.从指定的路径加载savepoint启动应用
4.注意：从savepoint中加载状态是通过算子id定位的，最好手动设置算子uid
相关文章：
猜你喜欢
相关资源
相似解决方案
热门标签