hbase java连接

xdyibdwo  于 2021-06-04  发布在  Hadoop
关注(0)|答案(2)|浏览(389)

我想通过java建立到hbase的连接,但我面临一个问题。我在centos 6.5上通过ambari安装了单节点HDP2.1。我有以下代码:

public class PutExample {
   public static void main(String[] args) throws IOException {

      final String serverFQDN = "hadoop.hortonworks";

      Configuration conf = HBaseConfiguration.create();
      conf.set("hbase.zookeeper.quorum", serverFQDN); 
      conf.set("hbase.zookeeper.property.clientPort", "2181");
      conf.set("zookeeper.znode.parent", "/hbase-unsecure");

      HBaseAdmin admin = new HBaseAdmin(conf);

      try {

          HTable table = new HTable(conf, "hb_tt2");

      } catch ( Exception ex ) {
          System.out.println("Error caught.");
          ex.printStackTrace();
      }

      System.out.println("End.");
   }
}

这是输出:

log4j:WARN No appenders could be found for logger (org.apache.hadoop.metrics2.lib.MutableMetricsFactory).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/C:/Users/bae/Desktop/Neue%20Bibliotheken/lib%20Hadoop/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/C:/Users/bae/Desktop/Neue%20Bibliotheken/lib%20Zookeeper/slf4j-log4j12-1.6.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
Error caught.
java.io.IOException: Unable to determine ZooKeeper ensemble
    at org.apache.hadoop.hbase.zookeeper.ZKUtil.connect(ZKUtil.java:121)
    at org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.<init>(ZooKeeperWatcher.java:165)
    at org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.<init>(ZooKeeperWatcher.java:134)
    at org.apache.hadoop.hbase.client.ZooKeeperKeepAliveConnection.<init>(ZooKeeperKeepAliveConnection.java:43)
    at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.getKeepAliveZooKeeperWatcher(ConnectionManager.java:1725)
    at org.apache.hadoop.hbase.client.ZooKeeperRegistry.isTableOnlineState(ZooKeeperRegistry.java:103)
    at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.isTableDisabled(ConnectionManager.java:926)
    at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.relocateRegion(ConnectionManager.java:1093)
    at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.locateRegionInMeta(ConnectionManager.java:1374)
    at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.locateRegion(ConnectionManager.java:1128)
    at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.locateRegion(ConnectionManager.java:1111)
    at org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.locateRegion(ConnectionManager.java:1070)
    at org.apache.hadoop.hbase.client.HTable.finishSetup(HTable.java:347)
    at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:201)
    at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:159)
    at bt.PutExample.main(PutExample.java:41)
End.

我没有更改任何配置文件,我使用在hadoop服务器上找到的jar文件。我的程序或服务器中是否缺少任何配置?我弄不清楚这个错误信息是什么意思。
提前谢谢你的帮助

qpgpyjmq

qpgpyjmq1#

尝试更改hbase jar的版本。有时小的改变会有帮助。我也遇到了同样的异常,将hbase客户机jar(pom.xml中)从0.98修改为0.98.4也很有帮助。

<version>0.98.4-hadoop2</version>
5tmbdcev

5tmbdcev2#

你需要把所有需要的jar放到hadoop\u类路径中
尝试使用这个字符串来执行jar

HADOOP_CLASSPATH=`hbase classpath` hadoop jar your.jar PutExample

相关问题