【发布时间】:2013-01-08 16:31:02
【问题描述】:
使用的组件:- -Ubuntu 12.04、hive(0.9.0)、hbase(0.94.3)、hadoop(0.20.2)-单节点、zookeeper-3.4.3、guava-11.0.2、hive-hbase-handler-0.9.0
教程:-https://cwiki.apache.org/confluence/display/Hive/HBaseIntegration
步骤 1)启动hadoop, 2) 启动 hbase-master 3)启动蜂巢服务器 4) 使用 --auxpath 参数启动 hive shell,如教程中所示 (所有工作都没有错误 - JobTracker、HRegionServer、HMaster、DataNode、NameNode、SecondaryNameNode、TaskTracker、HQuorumPeer、Jps)
hbase(main):001:0> status
1 servers, 0 dead, 2.0000 average load
在我创建的 hive shell 上可以创建表
CREATE TABLE IF NOT EXISTS familia (id_familia INT,fk_veiculo INT,fk_cliente INT,nome STRING) ROW FORMAT delimited fields terminated by ',' STORED AS TEXTFILE;
load data local inpath '/home/trendwise/hive_data/tables_csv/familia.csv' overwrite into table familia;
但是当我做下面的查询时,什么都没有显示,只是光标闪烁。我等了很长时间,然后显示错误
CREATE TABLE hbase_familia_1 (key int, id_familia int, fk_veiculo INT,fk_cliente INT,nome STRING)
STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler'
WITH SERDEPROPERTIES("hbase.columns.mapping" = ":key, cf1:id_familia, cf2:fk_veiculo,cf3:fk_cliente, cf4:nome")
TBLPROPERTIES ("hbase.table.name" = "hbase_familia");
我在 hbase shell 上做了list,但没有显示我尝试过的任何表格?
错误:-
FAILED: Error in metadata: MetaException(message:org.apache.hadoop.hbase.MasterNotRunningException: Retried 10 times
at org.apache.hadoop.hbase.client.HBaseAdmin.<init>(HBaseAdmin.java:127)
at org.apache.hadoop.hive.hbase.HBaseStorageHandler.getHBaseAdmin(HBaseStorageHandler.java:73)
at org.apache.hadoop.hive.hbase.HBaseStorageHandler.preCreateTable(HBaseStorageHandler.java:147)
at org.apache.hadoop.hive.metastore.HiveMetaStoreClient.createTable(HiveMetaStoreClient.java:398)
at org.apache.hadoop.hive.ql.metadata.Hive.createTable(Hive.java:538)
at org.apache.hadoop.hive.ql.exec.DDLTask.createTable(DDLTask.java:3305)
at org.apache.hadoop.hive.ql.exec.DDLTask.execute(DDLTask.java:242)
at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:134)
at org.apache.hadoop.hive.ql.exec.TaskRunner.runSequential(TaskRunner.java:57)
at org.apache.hadoop.hive.ql.Driver.launchTask(Driver.java:1326)
at org.apache.hadoop.hive.ql.Driver.execute(Driver.java:1118)
at org.apache.hadoop.hive.ql.Driver.run(Driver.java:951)
at org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java:258)
at org.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver.java:215)
at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:406)
at org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java:689)
at org.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java:557)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.apache.hadoop.util.RunJar.main(RunJar.java:156)
) FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask
hbase-site.xml
<property>
<name>hbase.rootdir</name>
<value>hdfs://localhost:54310/hbase</value>
</property>
<property>
<name>dfs.replication</name>
<value>1</value>
</property>
<property>
<name>hbase.zookeeper.property.dataDir</name>
<value>/home/trendwise/hadoop/hbase-0.94.3/hbase_dataDir</value>
</property>
<property>
<name>hbase.zookeeper.property.clientPort</name>
<value>2222</value>
<description>Property from ZooKeeper's config zoo.cfg.
</description>
</property>
<property>
<name>hbase.zookeeper.quorum</name>
<value>localhost</value>
<description></description>
</property>
<property>
<name>hbase.cluster.distributed</name>
<value>true</value>
<description></description>
</property>
【问题讨论】:
-
您是否确认您的 HMaster 正在使用
jps运行?您是否管理自己的 ZooKeeper 实例?如果没有,你不应该设置所有这些 ZooKeeper 属性,你可以在$HBASE_HOME/conf/hbase-env.sh中设置HBASE_MANAGES_ZK。 -
@Pieterjan,HMaster 在
jps之后运行,但没有 HRegionServer 和 HQuorumPeer,这些都这么重要吗?我没有管理自己的 ZooKeeper,所以我在 hbase-env 中取消注释export HBASE_MANAGES_ZK=true.sh & 撤销 hbase.cluster.distributedhbase.zookeeper.property.clientPort,hbase.z ookeeper.quorum 属性 -
没错。据我所知,只要 HBase 管理 ZooKeeper,就不需要运行 HRegionServer 和 HQuorumPeer。至少在伪分布式模式下是这样。进行这些更改后,您仍然会遇到相同的错误吗?你的日志文件说什么?