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> 总结合理的检查点与保存点策略可提升流作业的容错与演进能力。

发表评论 取消回复