Flink中的CheckpointCoordinator有什么作用?

提问者:帅平 问题分类:面试刷题
Flink中的CheckpointCoordinator有什么作用?
1 个回答
酷味有余
酷味有余
在 Apache Flink 中,CheckpointCoordinator 是 JobManager 的核心组件,负责分布式检查点(Checkpoint)的全生命周期管理,确保流处理作业的状态容错和 Exactly-Once 语义。它是 Flink 容错机制的关键实现者,协调所有任务(Task)的状态快照生成与恢复。CheckpointCoordinator 的主要作用是:
1、触发检查点(Checkpoint)
2、协调检查点生成
3、处理检查点确认(Acknowledge)
4、故障恢复与状态回滚
5、维护检查点元数据
发布于:1个月前 (05-16) IP属地:
我来回答