1 个回答
Flink中的重启策略有:
1、固定延迟重启策略:作业失败后,按固定延迟时间间隔重启,最多尝试指定次数。适用于对恢复时间要求不高,但需限制最大重试次数的场景(如实时ETL)。配置示例如下:
1、固定延迟重启策略:作业失败后,按固定延迟时间间隔重启,最多尝试指定次数。适用于对恢复时间要求不高,但需限制最大重试次数的场景(如实时ETL)。配置示例如下:
restart-strategy.fixed-delay.attempts:1(最大重启尝试次数)
restart-strategy.fixed-delay.delay:10s(两次重启之间的固定延迟(如 10 s))
2、失败率重启策略:在指定时间窗口内,允许作业失败一定次数,超过则停止重启。适用于允许短时间内多次失败但需防止无限重启的场景(如偶发外部依赖故障)。配置示例如下:restart-strategy: failure-rate
restart-strategy.failure-rate.max-failures-per-interval: 5 (时间窗口内允许的最大失败次数)
restart-strategy.failure-rate.failure-rate-interval: 5min (失败率计算的时间窗口(如 5 min))
restart-strategy.failure-rate.delay: 10s(两次重启之间的延迟时间)
3、不重启策略:作业失败后直接停止,不尝试重启。适用于测试环境或要求作业失败后人工介入的场景。配置示例如下:restart-strategy: none
发布于:3周前 (05-16) IP属地:
我来回答
您需要 登录 后回答此问题!