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

发表评论 取消回复