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 郝文强 <18...@163.com> on 2020/09/28 02:34:17 UTC

flunk - checkpoint


checkpoint 到底是在什么时间点触发的呢？
我看过官方关于checkpoint的文档，但还是说不清 checkpoint 是什么时候触发的求大佬指点
| |
郝文强
|
|
18846086541@163.com
|
签名由网易邮箱大师定制

Re: flunk - checkpoint

Posted by Congxian Qiu <qc...@gmail.com>.

Hi
   checkpoint 会按照用户设定的周期定期触发, 同时也会收到 minPauseBetweenCheckpoints 以及
maxConcurrentCheckpoints 等参数的控制，具体的可以看一下这个文档[1]，
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/state/checkpointing.html#enabling-and-configuring-checkpointing
Best,
Congxian


郝文强 <18...@163.com> 于2020年9月28日周一 上午10:34写道：

>
>
> checkpoint 到底是在什么时间点触发的呢？
> 我看过官方关于checkpoint的文档，但还是说不清 checkpoint 是什么时候触发的求大佬指点
> | |
> 郝文强
> |
> |
> 18846086541@163.com
> |
> 签名由网易邮箱大师定制
>
>

Re:flunk - checkpoint

Posted by hailongwang <18...@163.com>.

Source 算子的Checkpoint 是由 CheckpointCoordinator 周期性触发的（时间周期是自己设置的参数），然后下面的算子等到收到上游所有并发的barrier时，触发自己的Checkpoint（PS：1.11 目前 实现了 unaligned Checkpoint，无需对齐）。当Master 收到所有算子的 Checkpoint 完成后，会 notifyCheckpointComplete。
希望对你有帮助。
祝好。
Hailong Wang





在 2020-09-28 09:34:17，"郝文强" <18...@163.com> 写道：
>
>
>checkpoint 到底是在什么时间点触发的呢？
>我看过官方关于checkpoint的文档，但还是说不清 checkpoint 是什么时候触发的求大佬指点
>| |
>郝文强
>|
>|
>18846086541@163.com
>|
>签名由网易邮箱大师定制
>