You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by silence <sl...@aliyun.com.INVALID> on 2020/09/08 08:15:26 UTC

回复: flink-sql 1.11版本都还没完全支持checkpoint吗

手动停止再恢复的话需要启动时通过 (-s 上一次checkpoint的mate路径)进行恢复
https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/check
points.html#resuming-from-a-retained-checkpoint
-----邮件原件-----
发件人: 凌天荣 <46...@qq.com> 
发送时间: 2020年9月8日 15:50
收件人: user-zh <us...@flink.apache.org>
主题: flink-sql 1.11版本都还没完全支持checkpoint吗

代码里设置了enableCheckpointing，任务停掉后，重启，还是没能消费停掉期间的数
据，也就是checkpoint没生效