开发者社区> 问答> 正文

flink异常触发savepoint

请教老师,flink程序要停止的时候,都会手动去添加-s参数,去触发savepoint。但是如果程序是异常结束呢?要怎么去触发这个savepoint?*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-07 12:46:26 734 0
1 条回答
写回答
取消 提交回答
  • Hi 如果异常退出,你在enable externalized checkpoint时候会配置作业退出时候的checkpoint保留策略,默认是作业failed的时候会保留externalized checkpoint。 你可以在相关目录下找到相关checkpoint的目录(判断条件chk-X目录下是否有_metadata文件,如果存在的话,就可以认为这个checkpoint是有效的),这样你就可以使用-s 参数指定从该externalized checkpoint恢复,Flink会将该checkpoint当作savepoint处理进行作业恢复。*来自志愿者整理的flink

    2021-12-07 15:29:35
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载