---

title: Apache Flink 检查点与保存点实践

keywords:

  • Flink
  • Checkpoint
  • Savepoint
  • state.backend
  • checkpointing

description: 配置 Flink 检查点与保存点,提供 flink-conf 与 CLI 操作示例,保障状态一致性与回滚能力。

tags:

  • Checkpoint
  • Flink
  • Savepoint
  • checkpointing
  • state.backend
  • 后端
  • 流处理

categories:

  • 文章资讯
  • 技术教程

---

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 条评论

暂无评论
立即
投稿

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部