文档首页/ 数据湖探索 DLI/ 常见问题/ Flink作业类/ Flink作业咨询类/ 手动停止了Flink作业,再次启动时怎样从指定Checkpoint恢复?
更新时间:2024-11-06 GMT+08:00
分享

手动停止了Flink作业,再次启动时怎样从指定Checkpoint恢复?

问题现象

在创建Flink作业时开启了Checkpoint,指定了Checkpoint保存的OBS桶。手工停止Flink作业后,再次启动该Flink作业怎样从指定Checkpoint恢复。

解决方案

由于Flink Checkpoint和Savepoint生成机制及格式一致,因此可以通过Flink作业列表“操作”列中的“更多 > 导入保存点”,导入OBS中最新成功的Checkpoint,并从中恢复。

  1. 登录DLI管理控制台,选择“作业管理 > Flink作业”。
  2. 在对应Flink作业所在行,选择“操作 > 导入保存点”。
  3. 在导入保存点界面选择Checkpoint的OBS桶路径,Checkpoint保存路径为:“桶名/jobs/checkpoint/作业id开头的目录”。单击“确定”完成导入操作。
  4. 再次启动Flink作业,即从对应的检查点路径恢复作业。

相关文档