flink1.10checkpoint及savepoint实战

代码中配置状态后端和checkpoint的间隔时间及相关配置 1.flink-conf.yaml中配置Savepoint存储位置 不是必须设置,但是设置后,后面创建指定Job的Savepoint时,可以不用在手动执行命令时指定Savepoint的位置 2.取消任务并将savepoint保存到指定文件夹中 3.从指定的路径加载savepoint启动应用 4.注意:从savepoint中加载状态是通过
相关文章
相关标签/搜索