VIPFlink
Flink两阶段提交2PC是怎么实现的？为什么它能保证Sink不重复写
先抓住题目的核心考点，再把答案拆成可复述的面试表达。
17 次浏览2026/7/9
先下定义一句话说清它是什么，面试官先听到结论。
再讲机制拆出关键流程、边界条件和常见坑位。
最后落场景结合生产经验，说出什么时候用、怎么权衡。
题目描述
请回答：Flink两阶段提交2PC是怎么实现的？为什么它能保证Sink不重复写
这是Flink Exactly-Once里最容易被追问到Sink端细节的一题。很多人知道“Flink用两阶段提交”，但讲不清：第一阶段到底提交了什么？什么时候真正对外可见？Checkpoint失败怎么回滚？为什么Source和状态都没问题，Sink不配合还是做不到端到端Exactly-Once？
评论
加载中...