flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "baiyg25281@hundsun.com" <baiyg25...@hundsun.com>
Subject 回复: flink savepoints 和 checkpoints的区别
Date Wed, 27 Mar 2019 03:01:28 GMT
checkpoints:
    是程序运行中发生可恢复异常了,会从最新上一个checkpoint重新运行,一般代码中设置,就像你说的间隔几秒保存一次,只要设置了程序自动管理。

savepoints:
    是程序运行中断时使用,比如你要人为关闭任务进行维护,手动执行savepoints保存到指定路径。一般提交任务时会配置一个savepoints保存路径,这样程序运行发生重大故障中断了,会自动进行savepoints保存到你配置的路径。再次启动需要根据savepoints恢复中断前数据。





baiyg25281@hundsun.com
 
发件人: 九思
发送时间: 2019-03-27 10:48
收件人: user-zh
主题: flink savepoints 和 checkpoints的区别
请教老师,flink savepoints 和 checkpoints的区别,网络上是说,checkpoints主要用于异常恢复,savepoints主要用于程序恢复。。但是还是没搞懂,程序什么时候使用savepoints,什么时候使用savepoints。
PS:代码里有开启checkpoints, 3s一次。程序cancel的时候,会使用参数-s,强制savepoints。但是程序启动时,不知道该用savepoints来恢复,还是checkpoints来恢复?有什么区别嘛,谢谢。
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message