Flink 两阶段提交（Two-Phase Commit）是指在 Apache Flink 流处理框架中，为了保证分布式事务的一致性而采用的一种协议。它通常用于在流处理应用中处理跨多个分布式数据源的事务性操作，确保所有参与者（数据源或计算节点）在进行事务提交前达成一致，以避免数据不一致或丢失。
以下是 Flink 中实现两阶段提交的流程：
- 开始事务： 在 Flink 中，事务的开始通常与一个特定的时间窗口或者事件触发的状态更新相关。当一个事务开始时，Flink 会生成一个唯一的事务 ID，并将该 ID 关联到正在进行的事务。此时，事务的状态变更操作会被标记为属于该事务。
- 预提交： 在预提交阶段，Flink 会将事务的状态变更操作发送到涉及的不同任务或操作符中。这些任务或操作符会将事务操作收集到本地的状态中，但不会真正将这些操作应用到最终的状态中。
- 投票阶段： 一旦所有任务都接收并保存了事务的状态变更操作，Flink 将进入投票阶段。在这个阶段，各个任务会向协调者发送是否可以提交事务的投票。如果一个任务的状态变更操作成功保存，它会投票“同意”提交，否则投票“不同意”。
- 提交或中止： 协调者会等待所有参与者的投票结果。如果所有任务都投票“同意”，协调者会发送提交命令，各个任务会将之前保存的状态变更操作应用到最终状态中，从而完成事务。如果有任何一个任务投票“不同意”或者在一定时间内没有收到所有投票，协调者会发送中止命令，各个任务会回滚之前的状态变更操作，事务被中止。
Flink 两阶段提交协议的主要目标是保证所有参与者在进行事务提交或中止前达成一致&#
本文转载自: https://blog.csdn.net/u011095039/article/details/132166876
版权归原作者 贾斯汀玛尔斯 所有， 如有侵权，请联系我们删除。
版权归原作者 贾斯汀玛尔斯 所有， 如有侵权，请联系我们删除。