2

我创建了一个 hbase-hive 表。我通过蜂巢插入数据。

CREATE TABLE hivetest(cookie string, timespent string, pageviews string, visit string, logdate string) 
STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler'
WITH SERDEPROPERTIES ("hbase.columns.mapping" = "m:timespent, m:pageviews, m:visit, m:logdate")
TBLPROPERTIES ("hbase.table.name" = "hbasetest");

数据已正确插入。我可以使用 hbase shell 访问相同的数据。但是，我创建了一个 hbase 客户端，它在访问相同的数据时返回指向空的异常。

现在要注意的是，如果我创建一个虚拟 hbase 表并通过 hbase shell 而不通过HIVE放置一些数据并尝试从 hbase 客户端获取这些数据。它不会给出错误并返回数据。此外，如果我尝试通过 hbase 客户端将数据放入hbasetest表的某行，然后尝试获取同一行，也会发生同样的事情。现在这一次它给了我数据。

那么，我的问题是通过 hive 和 hbase shell 写入数据有什么区别？

Hbase客户端：

Configuration conf = HBaseConfiguration.create();
   Map variables = System.getenv();
   conf.set("hbase.zookeeper.quorum","192.168.0.92");
   HTable table;
   byte family[];
   byte qualifier[];           
   table = new HTable(conf, "hivetest");
   family = Bytes.toBytes("m");
   qualifier = Bytes.toBytes("logdate");             
   Get get = new Get(Bytes.toBytes("cookie_value"));    
   Result r = table.get(get);         
   byte  valueObj[] = r.getValue(family, qualifier);     
   byte  keyObj[] = r.getRow();
   String key = new String(keyObj);  
   String value = new String(valueObj);   /* line where exception occur */
   System.out.println((new StringBuilder(String.valueOf(key))).append(" = ").append(value).toString());

例外： 

Exception in thread "main" java.lang.NullPointerException
    at java.lang.String.<init>(Unknown Source)
    at com.hbase.test.HbaseExample.main(HbaseExample.java:51)
4

1 回答 1

3

您使用的是 hive 版本 0.9.0 吗？如果是这样，则该版本存在错误。HBaseStorageHandler 的 SerDe 不会忽略 comma 和 column family 之间的空格。这使得存储的列族的名称与您期望的不同。

HbaseExample 类中的第 51 行是什么？

 byte  valueObj[] = r.getValue(family, qualifier);

尝试在 SERDEPROPERTIES 映射中去掉逗号符号和列族之间的空格。

见：https ://issues.apache.org/jira/browse/HIVE-3243

于 2013-09-25T14:59:29.687 回答