首页 笔记 图片 查字 
所属分类:Flink
浏览:31
内容:

检查点(Checkpoint):
检查点是所有任务的状态在某个时间点的一份快照。将之前某个时间点所有的状态保存下来,这份存档就是检查点。
检查点是 Flink 容错机制的核心。

时间点就是所有任务都恰好处理完一个相同的输入数据的时候。

保存点(save point):
保存点是自定义的镜像保存功能。
保存点本质上是特殊的checkpoint,就是通过检查点的机制来创建流式作业状态的一致性镜像(consistent image)。
保存点中的状态快照是以算子ID和状态名称组织起来的,相当于一个键值对。