Source 算子的Checkpoint 是由 CheckpointCoordinator 周期性触发的（时间周期是自己设置的参数），然后下面的算子等到收到上游所有并发的barrier时，触发自己的Checkpoint（PS：1.11 目前 实现了 unaligned Checkpoint，无需对齐）。当Master 收到所有算子的 Checkpoint 完成后，会 notifyCheckpointComplete。 希望对你有帮助。 祝好。 Hailong Wang
在 2020-09-28 09:34:17，"郝文强" <[email protected]> 写道： > > >checkpoint 到底是在什么时间点触发的呢？ >我看过官方关于checkpoint的文档，但还是说不清 checkpoint 是什么时候触发的求大佬指点 >| | >郝文强 >| >| >[email protected] >| >签名由网易邮箱大师定制 >
