| 触发 | 手动 |
|---|---|
| 用途 | 版本升级/迁移 |
| 恢复 | 从 savepoint 启动 |
| 注意 | 算子 UID 必须稳定 |
Savepoint 操作
Savepoint 操作
flink savepoint <jobId> hdfs:///flink/savepoints
flink run -s hdfs:///flink/savepoints/savepoint-<id> -d new-job.jar
flink stop --savepointPath hdfs:///flink/savepoints <jobId>算子不指定 uid 时，逻辑调整后无法从保存点恢复状态。