[image: image.png]

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

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

> 没有指定savapoint的,我们是cancel掉,然后重新部署的
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "user-zh"
>                                                                     <
> [email protected]&gt;;
> 发送时间:&nbsp;2020年9月8日(星期二) 下午3:52
> 收件人:&nbsp;"user-zh"<[email protected]&gt;;
>
> 主题:&nbsp;Re: flink-sql 1.11版本都还没完全支持checkpoint吗
>
>
>
> 重启后有没有指定savepoint呢?
>
> 凌天荣 <[email protected]&gt; 于2020年9月8日周二 下午3:50写道:
>
> &gt; 代码里设置了enableCheckpointing,任务停掉后,重启,还是没能消费停掉期间的数据,也就是checkpoint没生效

回复