Recovery is suppressed by NoRestartBackoffTimeStrategy

在部署flink程序到独立的flink集群时，如果出现"Recovery is suppressed by NoRestartBackoffTimeStrategy"的错误，这通常是由于没有设置合适的重启策略导致的。为了解决这个问题，你可以按照以下引用内容中的方法进行设置。

你可以使用如下代码指定一个固定的重启策略：

env.setRestartStrategy(RestartStrategies.fixedDelayRestart(
  3, // 尝试重启的次数
  Time.of(10, TimeUnit.SECONDS) // 间隔
));

这样设置后，flink将会在程序失败后尝试重新启动，最多重启3次，每次间隔10秒。

另外，你也可以使用失败率重启策略：

val env = ExecutionEnvironment.getExecutionEnvironment()
env.setRestartStrategy(RestartStrategies.failureRateRestart(
  3, // 一个时间段内的最大失败次数
  Time.of(5, TimeUnit.MINUTES), // 衡量失败次数的时间段
  Time.of(10, TimeUnit.SECONDS) // 间隔
))

这种策略会根据指定的时间段内的失败次数来进行重启，最多重启3次，每次间隔10秒。

通过设置适当的重启策略，你应该能够解决"Recovery is suppressed by NoRestartBackoffTimeStrategy"的问题。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [flink 1.14.3集群jar部署Recovery is suppressed by NoRestartBackoffTimeStrategy](https://blog.csdn.net/liaomingwu/article/details/123051704)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v92^chatsearchT0_1"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]