从通过 hive 插入的 hbase 读取数据时出现问题答案

【问题标题】：Issue in reading data from hbase inserted through hive从通过 hive 插入的 hbase 读取数据时出现问题
【发布时间】：2013-09-29 18:26:06
【问题描述】：

我创建了一个 hbase-hive 表。我通过 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)

【问题讨论】：

标签： java hadoop hbase hive apache-zookeeper

【解决方案1】：

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

HbaseExample 类中的第 51 行是什么？

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

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

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

【讨论】：