flink写入hbase报错org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
时间: 2023-07-10 21:35:21 浏览: 296
kafka处理超大消息的配置 org.apache.kafka.common.errors.RecordTooLargeException
这个错误信息表明 Flink 作业遇到了无法恢复的错误并且已经停止了。在这种情况下,Flink 使用 NoRestartBackoffTimeStrategy 来防止无限重启作业。
要解决这个问题,你需要先了解导致作业失败的原因。可能是你的 HBase 配置有误,导致 Flink 在写入 HBase 时发生了错误。你可以检查一下 Flink 作业日志,看看是否有更详细的错误信息。如果有,可以根据错误信息来排查问题。
另外,你也可以尝试使用 Hadoop 的 Configuration 对象来配置 HBase 连接,例如:
```java
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 社区来获取更多帮助。
阅读全文