开发者社区> 问答> 正文

flink savepoint和checkpoint相关事项

Hi, flink的savepoint,checkpoint在任务如何修改的情况下还能沿用,如何修改下就只能重新消费了*来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-07 12:27:57 501 0
1 条回答
写回答
取消 提交回答
  • Hi

    在修改作业的情况下,从checkpoint恢复的主要措施是确保相关operator设置了uid[1],恢复state的时候添加了允许non-restored state [2] 恢复

    [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/savepoints.html#assigning-operator-ids [2] https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/savepoints.html#allowing-non-restored-state*来自志愿者整理的flink

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

相关电子书

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