在 Apache Flink 中，Savepoint 是一种手动触发的、用于备份和恢复作业状态的一致快照。查看 Savepoint 的“状态”通常包含两层含义：
下面分场景说明。
http://<jobmanager>:8081）Savepoint completed at ...
Savepoint stored at: hdfs:///savepoints/savepoint-xxxx
bin/flink savepoint <JobID> hdfs:///savepoints/
返回示例：
Savepoint completed. Path: hdfs:///savepoints/savepoint-abc123
✅ 有 Savepoint completed 即表示成功
hdfs dfs -ls hdfs:///savepoints/
# 或本地
ls -lh /savepoints/
正常 Savepoint 目录结构：
savepoint-<id>/
├── _metadata
├── data-xxx
✅ 关键文件：
_metadata（必须存在）data-*（状态数据）bin/flink savepoint -d hdfs:///savepoints/savepoint-xxx
可查看：
bin/flink run -s hdfs:///savepoints/savepoint-xxx ./job.jar
若失败，常见原因：
| 场景 | 判断方式 |
|---|---|
| 是否触发成功 | Web UI / 命令行输出 |
| 文件是否完整 | 检查 _metadata |
| 是否可用 | flink savepoint -d |
| 恢复是否成功 | Job 是否正常启动 |
如果你指的是 具体版本（如 Flink 1.12 / 1.18） 或 某种状态后端（RocksDB / HashMap），可以告诉我，我可以给你更具体的命令和排查方法。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
