开发者社区 问答 正文

Flink RestartStrategy 恢复策略

已解决

Flink RestartStrategy 恢复策略

展开
收起
提个问题 2024-06-01 19:03:02 53 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • 开发者社区问答官方账号
    官方回答
    采纳回答
    在遇到机器或者代码等不可预知的问题时导致 Job 或者 Task 挂掉的时候,它会根据配置的重启策略将 Job 或者受影响的 Task 拉起来重新执行,以使得作业恢复到之前正常执行状态。
    • FixedDelayRestartStrategy:程序按照集群配置文件中或者程序中额外设置的重启次数尝试重启作业,如果尝试次数超过了给定的最大次数,程序还没有起来,则停止作业,另外还可以配置连续两次重启之间的等待时间
    • FailureRateRestartStrategy:在发生故障之后重启作业,如果固定时间间隔之内发生故障的次数超过设置的值后,作业就会失败停止,该重启策略也支持设置连续两次重启之间的等待时间。
    • NoRestartStrategy:作业不重启策略,直接失败停止说明:如果程序没有启用 Checkpoint,则采用不重启策略。

    如果开启了 Checkpoint 且没有设置重启策略,那么采用固定延时重启策略,最大重启次数为 Integer.MAX_VALUE。

    详情请参考开源 Task Failure Recovery 文档。
    2024-06-01 19:03:03 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
问答标签:
问答地址:
关联地址:
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等