| 语义 | at least/exactly once |
|---|---|
| 手段 | 快照+两阶段提交 |
| 间隔 | 按恢复目标设定 |
| 存储 | HDFS/对象存储 |
开启与调参
开启与调参
-- flink-conf.yaml 关键项
-- execution.checkpointing.interval: 60s
-- execution.checkpointing.timeout: 10min
-- state.backend: rocksdb
-- state.checkpoints.dir: hdfs:///flink/checkpointsCheckpoint 目录要纳入容量监控，历史快照按保留策略清理。