0
点赞
收藏
分享

微信扫一扫

大数据_Flink_Java版_容错机制(5)-保存点---Flink工作笔记0074

RockYoungTalk 2022-03-24 阅读 58

然后我们再来看保存点,可以这样理解,保存点是手动的保存,检查点,这个是flink,会自动的隔一段时间就会自动的去保存.而保存点不会,他需要我们手动的去保存,他有强大的功能,

比如:手动备份不用说了.

然后这个更新应用程序,比如当我们的程序更新了,我们需要把之前所有的数据都重新跑一遍吗?

不需要对吧,我们一般都是更新前设置一个保存点,更新后,从这个保存点开始执行就可以了.

然后版本迁移,如果升级了flink的版本以后,也是,升级之前做个保存点,升级以后,然后不用把所有

数据都跑一遍了,只从保存点这里开始把数据继续跑就可以了.

然后我们再看,应用的暂停,重启,也是暂停之前我们设置一个保存点,然后

重启以后,我们从这个检查点再执行就可以了.

举报

相关推荐

0 条评论