| 作用 | 故障恢复的一致性基础 |
|---|---|
| 存储 | HDFS、S3、OSS 等可共享存储 |
| 配合 | 精确一次需要 checkpoint 与事务型 sink 共同实现 |
Flink 开启 checkpoint（Java）
Flink 开启 checkpoint（Java）
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableCheckpointing(60_000); // 每 60 秒一次
env.getCheckpointConfig().setMinPauseBetweenCheckpoints(30_000);
env.getCheckpointConfig().setCheckpointTimeout(10 * 60_000);checkpoint 持续变大通常意味着状态膨胀（key 基数增长或窗口过长），不治理会让恢复时间不断拉长。