Apache Flink 检查点与保存点实践

Apache Flink 检查点与保存点实践配置片段（flink-conf.yaml）state.backend: filesystem

state.checkpoints.dir: file:///tmp/flink-checkpoints

execution.checkpointing.interval: 1m

CLI 操作flink savepoint <jobId> file:///tmp/flink-savepoints

flink cancel -s file:///tmp/flink-savepoints/<savepointId> <jobId>

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