Hbase客户端无法连接本地Hbase服务器。

Question

Hbase客户端无法连接本地Hbase服务器。

3

我正试图运行一个简单的Hbase客户端程序，它与Hbase服务器（独立）通信，以创建一个表和一行数据。但是，很遗憾，在IntelliJ中运行时出现了以下异常：

Picked up JAVA_TOOL_OPTIONS: -Dfile.encoding=UTF-8
Initializing HBaseAdmin
log4j:WARN No appenders could be found for logger (org.apache.hadoop.security.Groups).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Hbase running, Creating table
Adding data into table
Exception in thread "main"  org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException: Failed 1 action: User: 1 time, 
at org.apache.hadoop.hbase.client.AsyncProcess$BatchErrors.makeException(AsyncProcess.java:205)
at org.apache.hadoop.hbase.client.AsyncProcess$BatchErrors.access$500(AsyncProcess.java:189)
at org.apache.hadoop.hbase.client.AsyncProcess.getErrors(AsyncProcess.java:1042)
at org.apache.hadoop.hbase.client.HTable.backgroundFlushCommits(HTable.java:1037)
at org.apache.hadoop.hbase.client.HTable.flushCommits(HTable.java:1352)
at org.apache.hadoop.hbase.client.HTable.put(HTable.java:963)
at HbaseSample.main(HbaseSample.java:22)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:497)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
Done

客户端程序：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.HBaseAdmin;

import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.*;

public class HbaseSample {
public static void main(String[] args) throws Exception {
    System.out.println("Initializing HBaseAdmin");
    Configuration conf = HBaseConfiguration.create();
    conf.set("hbase.zookeeper.property.clientPort","2181");
    conf.set("hbase.master", "localhost:60000");
    HBaseAdmin admin = new HBaseAdmin(conf);
    try {
        HBaseAdmin.checkHBaseAvailable(conf);
        System.out.println("Hbase running, Creating table");
        HTable table = new HTable(conf, "User");
        Put put = new Put(Bytes.toBytes("msameer"));
        put.add(Bytes.toBytes("Info"), Bytes.toBytes("addr"), Bytes.toBytes("walnut creek"));
        System.out.println("Adding data into table");
        table.put(put);
    } finally {
        admin.close();
        System.out.println("Done");
    }
  }
}

我的hbase-site.xml如下所示：

<configuration>
<property>
  <name>hbase.rootdir</name>
  <value>file:///Users/msameer/Documents/Hbase/hbase-root</value>
</property>
<property>
  <name>hbase.zookeeper.property.dataDir</name>
  <value>/Users/msameer/Documents/Hbase/hbase-zookeper</value>
</property>
<property>
   <name>hbase.zookeeper.property.clientPort</name>
   <value>2181</value>
</property>
<property>
  <name>hbase.master</name>
  <value>localhost:60000</value>
</property>
</configuration>

非常感谢您的帮助。

- MSameer

HBase 的哪个版本？ - Martin Serrano

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Martin Serrano · Accepted Answer

您的表已经存在吗？因为这段代码不会创建表：

HBaseAdmin.checkHBaseAvailable(conf);
System.out.println("Hbase running, Creating table");
HTable table = new HTable(conf, "User");

这将仅使用已经存在的表。要创建表格，您需要使用HBaseAdmin：

HBaseAdmin.checkHBaseAvailable(conf);
System.out.println("Hbase running, Creating table");
HTableDescriptor des = new HTableDescriptor("User");
HBaseAdmin.createTable(des);

请查看模式创建文档，其中还展示了更新后的API调用。以H开头的类已经被弃用。