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 社区来获取更多帮助。

相关问题

flink写入hbase报错org.apache.commons.io.IOUtils.closeQuietly(Ljava/io/Closeable;)V

这个报错是因为您的 Flink 代码中使用了一个已经被废弃的方法 `IOUtils.closeQuietly()`，而该方法在 Flink 的依赖库中已被移除。最好的解决方法是将该方法替换为 `org.apache.flink.shaded.guava18.com.google.common.io.Closer` 中的 `close()` 方法，该方法可以安全地关闭任何实现了 `java.io.Closeable` 接口的对象。您可以按照以下步骤进行替换：

1. 从 Maven 仓库中下载 `guava-18.0.jar`。
2. 将 `guava-18.0.jar` 添加到 Flink 项目的 classpath 中。
3. 在您的代码中替换 `IOUtils.closeQuietly()` 方法为 `Closer.close()` 方法。

示例代码如下：

import org.apache.flink.shaded.guava18.com.google.common.io.Closer;
import java.io.IOException;

public class Example {
    public static void main(String[] args) throws IOException {
        Closer closer = Closer.create();
        try {
            // your HBase write code here
        } catch (Throwable t) {
            throw closer.rethrow(t);
        } finally {
            closer.close();
        }
    }
}

这段代码创建了一个 `Closer` 对象，您需要将您的 HBase 写入代码包装在 `try` 代码块中，然后通过 `Closer.rethrow()` 将任何抛出的异常重新抛出，最后在 `finally` 代码块中调用 `Closer.close()` 方法关闭资源。

org.apache.flink.runtime.jobexception: recovery is suppressed by norestartbackofftimestrategy

### 回答1：
这个错误信息来自于 Apache Flink 分布式计算框架，意思是 Flink 作业的恢复（recovery）被“norestartbackofftimestrategy”策略所抑制（suppressed）。

通常情况下，当 Flink 作业由于某种原因失败时，Flink 会尝试重新启动作业以进行恢复。但是，如果采用了“norestartbackofftimestrategy”策略，当作业失败时，Flink 不会尝试重新启动作业，而是按照预定义的时间间隔进行重试，直到达到最大重试次数或者手动启动作业为止。这通常是由于管理员决定禁止自动重启来避免系统过载或其他问题。

### 回答2：
这个错误信息提示了一种叫做“norestartbackofftimestrategy”的恢复策略正在禁止任务重启。这个错误通常出现在Flink应用程序的运行过程中，表明Flink尝试恢复失败的任务时，出现了该恢复策略的限制。

"norestartbackofftimestrategy"是一种高级恢复策略，它限制了 Flink 在某些条件下尝试恢复失败任务的次数和间隔时间。该策略会拒绝 Flink 尝试重启宕机的任务，并且会设置一个无限的恢复间隔时间，这样就防止了任务频繁的重启，避免了占用过多的计算资源。

当 Flink 尝试恢复失败任务时，如果启用了“norestartbackofftimestrategy”，但是该恢复策略设置了不可恢复或者间隔时间过长的条件，那么就会抛出该异常，阻止 Flink 对该任务进行重启。

如果出现了此类错误，需要仔细检查是否启用了“norestartbackofftimestrategy”策略，并确认它的参数是否 设置得太严格或设置不当，导致任务无法恢复。在正确设置恢复策略的前提下，出现无法恢复的情况建议手动重启任务或检查程序代码是否存在问题。

### 回答3：
org.apache.flink.runtime.jobexception: recovery is suppressed by norestartbackofftimestrategy是Flink运行作业时可能出现的错误，它提示作业恢复被norestartbackofftimestrategy所抑制。

在Flink中，作业恢复是在作业出现故障或节点故障时采取的一项重要措施。一般来说，Flink会尝试恢复作业，以确保数据的完整性和一致性，并尽可能避免数据丢失和重复执行。

然而，当发生频繁的故障时，这种自动恢复可能会导致更多的问题。这时，Flink就会采用一种名为norestartbackofftimestrategy的策略来抑制作业的恢复。它的作用是在一定的时间内，暂停自动重启作业，以防止故障的再次出现。

因此，当出现org.apache.flink.runtime.jobexception: recovery is suppressed by norestartbackofftimestrategy错误时，可能是由于作业故障导致Flink引擎采用了这种策略来控制作业的恢复。在这种情况下，需要重新检查作业配置和代码实现是否存在问题，以及所用的资源是否足够满足作业的需求。

总之，org.apache.flink.runtime.jobexception: recovery is suppressed by norestartbackofftimestrategy错误是Flink运行时的一个比较常见的错误，需要认真排查和解决。只有通过有效的措施，才能确保作业恢复的顺利进行，同时保障数据的安全和完整性。