flink 设置并行数后报错：Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=3, backoffTimeMS=5000)

这个错误信息表明 Flink 作业在达到最大重启次数后被终止，且不会进行自动恢复。该行为由 Flink 的重启策略所决定，根据错误信息中提到的 `FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=3, backoffTimeMS=5000)` 可以看出，Flink 使用了固定延迟的重启策略。

这个策略的意思是，当作业失败并触发重启时，Flink 会等待一段固定的时间（这里是5000毫秒），然后尝试重新启动作业。如果重启次数超过了设定的最大次数（这里是3次），则会放弃重启并终止作业。

这个错误通常是由于作业在启动过程中遇到了无法恢复的错误，导致达到了最大重启次数。你可以检查 Flink 作业的日志或错误信息，以确定具体的失败原因。常见的原因可能包括代码错误、资源不足、外部系统故障等。

解决该问题的方法取决于具体的失败原因。你可以尝试增加最大重启次数或延长重启间隔时间，以便给作业更多的恢复机会。另外，还可以通过调试代码、优化作业逻辑或增加资源来解决特定的问题。

请注意，重新调整重启策略需要根据具体情况谨慎操作，以避免无限制地重启作业。

相关问题

flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=30, backoffTimeMS=30000)

这个错误是 Flink 在执行任务时发生的异常，通常是由于任务失败而触发的自动重启机制。在这个特定的错误中，Flink 选择了一种名为 FixedDelayRestartBackoffTimeStrategy 的重启策略，它会在每次重启之间等待一段固定的时间（30秒），并且最多尝试重启任务 30 次。如果达到最大重启次数而任务仍然无法成功运行，则 Flink 将停止尝试重启，这时你需要检查任务的代码和配置，以找出问题的根本原因。

flink写入hbase报错org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy

这个错误信息表明 Flink 作业遇到了无法恢复的错误并且已经停止了。在这种情况下，Flink 使用 NoRestartBackoffTimeStrategy 来防止无限重启作业。

要解决这个问题，你需要先了解导致作业失败的原因。可能是你的 HBase 配置有误，导致 Flink 在写入 HBase 时发生了错误。你可以检查一下 Flink 作业日志，看看是否有更详细的错误信息。如果有，可以根据错误信息来排查问题。

另外，你也可以尝试使用 Hadoop 的 Configuration 对象来配置 HBase 连接，例如：

Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "localhost");
config.set("hbase.zookeeper.property.clientPort", "2181");
config.set("hbase.master", "localhost:60000");

然后在 Flink 的代码中使用这个 Configuration 对象来连接 HBase。

如果以上方法都无法解决问题，你可以考虑联系 Flink 社区来获取更多帮助。