开发者社区 问答 正文

Flink两次checkpoint最小间隔时间如何计算

已解决

Flink两次checkpoint最小间隔时间如何计算

展开
收起
阿里云服务支持 2022-12-16 13:17:01 691 分享 版权
1 条回答
写回答
取消 提交回答
  • 官方回答

    最小间隔时间是按照上次成功的checkpoint开始计算PS:

    配置间隔时间为3s,最小间隔时间为5s,这种情况下,间隔时间会调整为5s 即: execution.checkpointing.interval配置为3s,execution.checkpointing.min-pause配置为5s。 以两个场景进行说明,两个场景checkpoint间隔时间为3分钟,超时时间为10分钟,最小间隔时间为5分钟。

    ● 场景一:作业正常运行(checkpoint每次都成功)12:00第一次开始执行checkpoint,12:00:02 checkpoint 成功,第二次checkpoint开始时间为12:05:02。

    ● 场景二:作业不正常(checkpoint因某些原因超时或者失败,本次场景以超时为例)12:00第一次开始执行checkpoint,12:00:02 checkpoint 成功-->>12:05:02第二次开始执行checkpoint,12:15:02超时失败,第三次checkpoint开始时间为12:15:02。

    2022-12-16 13:20:29
    赞同 展开评论
收录在圈子:
作为全球云计算的领先者,阿里云为全球230万企业提供着云计算服务,服务范围覆盖200多个国家和地区。我们致力于为企业、政府等组织机构提供安全可靠的云计算服务,给用户带来极速愉悦的服务体验。
还有其他疑问?
咨询AI助理