开发者社区 问答 正文

flink异常恢复

讨论下flink异常重启问题 从kafka消费数据,checkpoint周期在5分钟,如果在第6分钟,因为异常导致flink任务重启,flink是从上个checkpoint恢复呢?还是从异常时的offset恢复呢?*来自志愿者整理的flink邮件归档

展开
收起
小阿怪 2021-12-07 22:05:36 481 分享 版权
1 条回答
写回答
取消 提交回答
  • 上个checkpoint*来自志愿者整理的flink邮件归档

    2021-12-08 10:28:01
    赞同 展开评论