flink 设置并行数后报错:Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=3, backoffTimeMS=5000)
时间: 2023-08-17 21:02:20 浏览: 802
改进的CK-means优化及并行策略
这个错误信息表明 Flink 作业在达到最大重启次数后被终止,且不会进行自动恢复。该行为由 Flink 的重启策略所决定,根据错误信息中提到的 `FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=3, backoffTimeMS=5000)` 可以看出,Flink 使用了固定延迟的重启策略。
这个策略的意思是,当作业失败并触发重启时,Flink 会等待一段固定的时间(这里是5000毫秒),然后尝试重新启动作业。如果重启次数超过了设定的最大次数(这里是3次),则会放弃重启并终止作业。
这个错误通常是由于作业在启动过程中遇到了无法恢复的错误,导致达到了最大重启次数。你可以检查 Flink 作业的日志或错误信息,以确定具体的失败原因。常见的原因可能包括代码错误、资源不足、外部系统故障等。
解决该问题的方法取决于具体的失败原因。你可以尝试增加最大重启次数或延长重启间隔时间,以便给作业更多的恢复机会。另外,还可以通过调试代码、优化作业逻辑或增加资源来解决特定的问题。
请注意,重新调整重启策略需要根据具体情况谨慎操作,以避免无限制地重启作业。
阅读全文