Flink job级别的容错是什么?RestartStrategy
Flink job级别的容错是通过RestartStrategy实现的。RestartStrategy定义了Flink在发生故障时如何重新启动作业。Flink支持以下四种RestartStrategy:
-
NoRestartStrategy:不重启作业,直接失败。
-
FixedDelayRestartStrategy:在发生故障时,等待一段时间后重新启动作业,重试固定次数。
-
FailureRateRestartStrategy:在一段时间内,如果失败次数超过一定阈值,就重启作业。
-
FullRestratStrategy:发生故障时,重启作业,无限重试。
在选择RestartStrategy时,需要根据作业的需求和实际情况进行选择。例如,如果作业需要高可用性,则可以选择FixedDelayRestartStrategy或FailureRateRestartStrategy;如果作业的计算量较大,需要保证结果的准确性,则可以选择FullRestratStrategy。
原文地址: https://www.cveoy.top/t/topic/f6pK 著作权归作者所有。请勿转载和采集!