Flink Checkpoint与Exactly-Once：状态一致性与反压治理

Flink Checkpoint与Exactly-Once：状态一致性与反压治理概览Flink 通过 Checkpoint 与状态后端保障一致性；与两阶段提交 sink 配合实现端到端 Exactly-Once。反压与恢复策略影响延迟与稳定性。技术参数（已验证）Checkpoint：周期触发与 barrier 对齐；支持 `unaligned checkpoints` 降低反压影响。状态后端：RocksDB/HeapState；在大状态下优先 RocksDB 并调优 IO 与内存。两阶段提交：`TwoPhaseCommitSink` 将偏移与写入在提交点原子化；避免重复写与丢失。Savepoint：用于有状态作业迁移与升级；区别于故障恢复的 Checkpoint。观测：记录反压、Checkpoint 时长与失败；设定告警与回退策略。实战清单启用合适的 Checkpoint 间隔与超时；在长尾场景考虑 `unaligned`。对 sink 采用两阶段提交或幂等写入；保持恢复路径幂等。建立反压监控与调参手册；在变更前执行演练与压测。