何时关闭 hbase 连接以及如果连接未关闭会发生什么

Question

我是 hbase 新手。我想对不同的表执行 2 次扫描操作。 所以我有返回遗传函数来扫描并在 scala 结束时关闭连接。

functionhbasescan(Tablename1, scanfield) fuctionhbasescan(Tablename2, scanfield)

当我调用表名 1 的函数时，它运行良好并返回了结果。 但是当我为表名 2 调用相同的函数时，它说连接已关闭。

scala 中的实例是否只建立了一个连接？我们需要在驱动程序的进程结束时关闭连接吗？

请帮助我了解连接过程及其工作原理。

注意：(HConnectionManager)使用connectionfactory.createconnection建立连接，然后是connection.getTable。

Answer 1

根据提供的信息不确定，但连接可能已被第一个函数关闭。你可以

• 检查连接isClosed 是否如文档所述 https://hbase.apache.org/apidocs/org/apache/hadoop/hbase/client/Connection.html 如有必要，使用createConnection 创建另一个连接（请参阅 https://hbase.apache.org/apidocs/org/apache/hadoop/hbase/client/ConnectionFactory.html)
• 在完成之前不要关闭连接。将连接上的close 调用移到内部函数调用之外，并等待两次扫描完成，然后关闭连接。