Flink job级别的容错是通过RestartStrategy实现的。RestartStrategy定义了Flink在发生故障时如何重新启动作业。Flink支持以下四种RestartStrategy:

  1. NoRestartStrategy:不重启作业,直接失败。

  2. FixedDelayRestartStrategy:在发生故障时,等待一段时间后重新启动作业,重试固定次数。

  3. FailureRateRestartStrategy:在一段时间内,如果失败次数超过一定阈值,就重启作业。

  4. FullRestratStrategy:发生故障时,重启作业,无限重试。

在选择RestartStrategy时,需要根据作业的需求和实际情况进行选择。例如,如果作业需要高可用性,则可以选择FixedDelayRestartStrategy或FailureRateRestartStrategy;如果作业的计算量较大,需要保证结果的准确性,则可以选择FullRestratStrategy。

Flink job级别的容错是什么?RestartStrategy

原文地址: https://www.cveoy.top/t/topic/f6pK 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录