生产建议的检查点配置
生产建议的检查点配置
SET 'execution.checkpointing.interval' = '30s';
SET 'execution.checkpointing.mode' = 'EXACTLY_ONCE';
-- 恢复示例：flink run -s :savepointPath: -c 主类 app.jar| 位点提交时机 | 随 checkpoint 完成 |
|---|---|
| 恢复语义 | 从最近检查点续读，可能重复少量事件 |
| 下游要求 | upsert/幂等写入消化重复 |
| 间隔权衡 | 过小：检查点开销大；过大：恢复回放量大 |
端到端不重复还取决于 sink 是否支持事务或幂等：EXACTLY_ONCE 检查点不等于端到端精确一次。