手动停止了Flink作业,再次启动时没有提示从哪个Checkpoint恢复
问题现象
在创建Flink作业时开启了Checkpoint,指定了Checkpoint保存的OBS桶。手工停止Flink作业后,再次启动该Flink作业没有提示从哪个Checkpoint恢复。
解决方案
由于Flink Checkpoint和Savepoint生成机制及格式一致,因而,也可以通过Flink作业列表“操作”列中的“更多 > 导入保存点”,导入OBS中最新成功的Checkpoint,并从中恢复。
- 登录DLI管理控制台,选择“作业管理 > Flink作业”。
- 在对应Flink作业所在行,选择“操作 > 导入保存点”。
- 在导入保存点界面选择Checkpoint的OBS桶路径,Checkpoint保存路径为:“桶名/jobs/checkpoint/作业id开头的目录”。单击“确定”完成导入操作。
- 再次启动Flink作业,即从对应的检查点路径恢复作业。