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

点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论
立即
投稿

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部