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 凌天荣 <46...@qq.com> on 2020/09/08 07:50:00 UTC
flink-sql 1.11版本都还没完全支持checkpoint吗
代码里设置了enableCheckpointing，任务停掉后，重启，还是没能消费停掉期间的数据，也就是checkpoint没生效
Re: flink-sql 1.11版本都还没完全支持checkpoint吗
Posted by Peihui He <pe...@gmail.com>.
[image: image.png]
重新部署如果需要从上次cancel点恢复的化，需要指定savepoint，savepoint 可以是上次cancel点最后一次checkpoint。
凌天荣 <46...@qq.com> 于2020年9月8日周二 下午4:07写道：
> 没有指定savapoint的，我们是cancel掉，然后重新部署的
>
>
> ------------------ 原始邮件 ------------------
> 发件人:
> "user-zh"
> <
> peihuihe@gmail.com>;
> 发送时间: 2020年9月8日(星期二) 下午3:52
> 收件人: "user-zh"<user-zh@flink.apache.org>;
>
> 主题: Re: flink-sql 1.11版本都还没完全支持checkpoint吗
>
>
>
> 重启后有没有指定savepoint呢？
>
> 凌天荣 <466792133@qq.com> 于2020年9月8日周二 下午3:50写道：
>
> > 代码里设置了enableCheckpointing，任务停掉后，重启，还是没能消费停掉期间的数据，也就是checkpoint没生效
回复： flink-sql 1.11版本都还没完全支持checkpoint吗
Posted by 凌天荣 <46...@qq.com>.
没有指定savapoint的，我们是cancel掉，然后重新部署的
------------------ 原始邮件 ------------------
发件人: "user-zh" <peihuihe@gmail.com>;
发送时间: 2020年9月8日(星期二) 下午3:52
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: flink-sql 1.11版本都还没完全支持checkpoint吗
重启后有没有指定savepoint呢？
凌天荣 <466792133@qq.com> 于2020年9月8日周二 下午3:50写道：
> 代码里设置了enableCheckpointing，任务停掉后，重启，还是没能消费停掉期间的数据，也就是checkpoint没生效
Re: flink-sql 1.11版本都还没完全支持checkpoint吗
Posted by Peihui He <pe...@gmail.com>.
重启后有没有指定savepoint呢？
凌天荣 <46...@qq.com> 于2020年9月8日周二 下午3:50写道：
> 代码里设置了enableCheckpointing，任务停掉后，重启，还是没能消费停掉期间的数据，也就是checkpoint没生效
回复: flink-sql 1.11版本都还没完全支持checkpoint吗
Posted by silence <sl...@aliyun.com.INVALID>.
手动停止再恢复的话需要启动时通过 (-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没生效