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 08:04:47 UTC
回复： flink-sql 1.11版本都还没完全支持checkpoint吗
没有指定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>.
[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没生效