在 Flink 中,一个算子是如何感知并触发 Checkpoint 的?
考察说明
考察对 Flink Checkpoint 机制的理解,包括触发、传播与执行流程
回答思路
- 说明 Checkpoint 由 JobManager 定期触发,向 Source 算子发送 Barrier
- 解释 Barrier 如何随数据流在算子间传播,实现 Chandy-Lamport 分布式快照
- 描述算子接收到 Barrier 后如何备份自身状态(State)
- 提及对齐(aligned)与非对齐(unaligned)Checkpoint 的差异及其影响
本题已收录答题指导
本题附完整参考答案与评分标准
登录后可查看结构化答题指导;也可以直接开一场模拟面试,AI 面试官用本题实时追问并给出评分。