Flink的4种重启策略

Posted 二十六画生的博客

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink的4种重启策略相关的知识,希望对你有一定的参考价值。

如果checkpoint未启动,就会采用no restart策略;

如果启动了checkpoint机制,但是未指定重启策略的话,就会采用fixed-delay策略,重试Integer.MAX_VALUE次。

分别是:

1 固定间隔 (Fixed delay)

For example:

restart-strategy.fixed-delay.attempts: 3
restart-strategy.fixed-delay.delay: 10 s

失败后,重启3次(每次重启间隔10s),如果第3次还是失败,则任务最终是失败,不再重启。

2 失败率 (Failure rate)

For example:

restart-strategy.failure-rate.max-failures-per-interval: 3
restart-strategy.failure-rate.failure-rate-interval: 5 min
restart-strategy.failure-rate.delay: 10 s

失败后,5分钟内重启3次(每次重启间隔10s),如果第3次还是失败,则任务最终是失败,不再重启。

3 无重启 (No restart)

第一次失败后就最终失败,不再重启。

4 Fallback(备用重启策略)

使用集群定义的重启策略。

参考:

https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/restart_strategies.html#fallback-restart-strategy

以上是关于Flink的4种重启策略的主要内容,如果未能解决你的问题,请参考以下文章

Flink重启策略机制

从0到1Flink的成长之路(二十)-Flink 高级特性之自动重启策略和恢复

Flink重启策略 flink出现异常重新拉起任务

Flink 任务失败重启与恢复策略

Flink 任务失败重启与恢复策略

从0到1Flink的成长之路(二十)-Flink 高级特性之状态恢复和重启策略