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

[凌天荣]

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

[Peihui He]

重启后有没有指定savepoint呢？

凌天荣 <[hidden email]> 于2020年9月8日周二 下午3:50写道：

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

[凌天荣]

没有指定savapoint的，我们是cancel掉，然后重新部署的


------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年9月8日(星期二) 下午3:52
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: flink-sql 1.11版本都还没完全支持checkpoint吗



重启后有没有指定savepoint呢？

凌天荣 <[hidden email]&gt; 于2020年9月8日周二 下午3:50写道：

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

[silence-2]

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

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

[Peihui He]

重新部署如果需要从上次cancel点恢复的化，需要指定savepoint，savepoint 可以是上次cancel点最后一次checkpoint。

凌天荣 <[hidden email]> 于2020年9月8日周二 下午4:07写道：

没有指定savapoint的，我们是cancel掉，然后重新部署的


------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年9月8日(星期二) 下午3:52
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: flink-sql 1.11版本都还没完全支持checkpoint吗



重启后有没有指定savepoint呢？

凌天荣 <[hidden email]&gt; 于2020年9月8日周二 下午3:50写道：

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