Flink的4种重启策略
Posted 二十六画生的博客
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink的4种重启策略相关的知识,希望对你有一定的参考价值。
如果checkpoint未启动,就会采用no restart策略;
如果启动了checkpoint机制,但是未指定重启策略的话,就会采用fixed-delay策略,重试Integer.MAX_VALUE次。
分别是:
- Fixed Delay Restart Strategy
- Failure Rate Restart Strategy
- No Restart Strategy
- Fallback Restart Strategy
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(备用重启策略)
使用集群定义的重启策略。
参考:
以上是关于Flink的4种重启策略的主要内容,如果未能解决你的问题,请参考以下文章