知识卡片
Checkpoint备份本地状态
内容
Checkpoint 定期把本地状态保存到可靠存储,故障后从备份恢复,并为 Flink 内部提供 Exactly-Once 保障。发散:流计算可靠性的核心不是不失败,而是失败后能回到一致位置。
参考来源
- 位置:《Flink原理与实践》第6章《状态和检查点》(源文件:_epub-src/OEBPS/Text/chapter09.xhtml)
- 结论依据:原文围绕“Checkpoint为Flink提供了Exactly-Once”给出定义、流程、对比或限制条件,本卡片据此提炼其可迁移的框架机制,并补充了使用边界或工程启发。
- 原始内容:定期保存状态数据到存储空间上,故障发生后从之前的备份中恢复,这个过程被称为Checkpoint机制。Checkpoint为Flink提供了Exactly-Once的投递保障。本节将介绍Flink的Checkpoint机制的原理,会使用多个概念:快照(Snapshot)、分布式快照(Distribut……