Apache Flink 检查点与保存点实践

配置片段（flink-conf.yaml）

state.backend: filesystem
state.checkpoints.dir: file:///tmp/flink-checkpoints
execution.checkpointing.interval: 1m

CLI 操作

flink savepoint  file:///tmp/flink-savepoints
flink cancel -s file:///tmp/flink-savepoints/ 

总结

合理的检查点与保存点策略可提升流作业的容错与演进能力。