Flink 有重启策略,可以在出现故障时自动重启任务以保持数据处理的连续性。Flink 提供以下五种重启策略:

  1. 'NoRestart':不进行重启,任务一旦失败就直接停止。

  2. 'FixedDelayRestart':固定时间间隔重启,即在任务失败后等待指定时间后进行重启。可以指定重启次数和重启间隔时间。

  3. 'FailureRateRestart':失败率重启,可以设置一定时间内任务失败的最大次数和重启次数。如果任务失败率超过设定值,则触发重启。

  4. 'RestartPipelinedRegion':基于任务拓扑结构的重启策略,当某个算子失败后,只重启该算子的下游算子,而不是整个任务。

  5. 'FallbackRestart':使用备用算子作为重启策略,当某个算子失败后,使用备用算子代替该算子进行处理。

Flink 重启策略:五种常见的重启策略解析

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

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