`
weitao1026
  • 浏览: 1053575 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

在Windows上直接使用JAVA API连接Hbase0.96报的一个异常

阅读更多

在Windows上直接使用JAVA API连接Hbase0.96报的一个异常,这个异常在Hbase0.94的版本里是没有的,为什么?  跟你所用的底层的Hadoop有关系,如果是底层hadoop是1.x的版本,那么没有这个问题,如果是2.x的hadoop,那么需要注意了,可能会出现下面这个问题,异常如下:

Java代码 复制代码 收藏代码
  1. 2014-07-14 13:27:59,286 WARN  [org.apache.hadoop.util.NativeCodeLoader] Unable to load native-hadoop library for your platform... using builtin-java classes where applicable  
  2. 2014-07-14 13:27:59,317 ERROR [org.apache.hadoop.util.Shell] Failed to locate the winutils binary in the hadoop binary path  
  3. java.io.IOException: Could not locate executable D:\hadoop-1.2.0\bin\winutils.exe in the Hadoop binaries.  
  4.     at org.apache.hadoop.util.Shell.getQualifiedBinPath(Shell.java:278)  
  5.     at org.apache.hadoop.util.Shell.getWinUtilsPath(Shell.java:300)  
  6.     at org.apache.hadoop.util.Shell.<clinit>(Shell.java:293)  
  7.     at org.apache.hadoop.util.StringUtils.<clinit>(StringUtils.java:76)  
  8.     at org.apache.hadoop.conf.Configuration.getStrings(Configuration.java:1514)  
  9.     at org.apache.hadoop.hbase.zookeeper.ZKConfig.makeZKProps(ZKConfig.java:113)  
  10.     at org.apache.hadoop.hbase.zookeeper.ZKConfig.getZKQuorumServersString(ZKConfig.java:265)  
  11.     at org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.<init>(ZooKeeperWatcher.java:159)  
  12.     at org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.<init>(ZooKeeperWatcher.java:134)  
  13.     at org.apache.hadoop.hbase.client.ZooKeeperKeepAliveConnection.<init>(ZooKeeperKeepAliveConnection.java:43)  
  14.     at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.getKeepAliveZooKeeperWatcher(HConnectionManager.java:1710)  
  15.     at org.apache.hadoop.hbase.client.ZooKeeperRegistry.getClusterId(ZooKeeperRegistry.java:82)  
  16.     at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.retrieveClusterId(HConnectionManager.java:806)  
  17.     at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.<init>(HConnectionManager.java:633)  
  18.     at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)  
  19.     at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)  
  20.     at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)  
  21.     at java.lang.reflect.Constructor.newInstance(Constructor.java:513)  
  22.     at org.apache.hadoop.hbase.client.HConnectionManager.createConnection(HConnectionManager.java:387)  
  23.     at org.apache.hadoop.hbase.client.HConnectionManager.createConnection(HConnectionManager.java:366)  
  24.     at org.apache.hadoop.hbase.client.HConnectionManager.getConnection(HConnectionManager.java:247)  
  25.     at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:188)  
  26.     at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:150)  
  27.     at com.dhgate.ywhbase.test.QueryTest.main(QueryTest.java:43)  
2014-07-14 13:27:59,286 WARN  [org.apache.hadoop.util.NativeCodeLoader] Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2014-07-14 13:27:59,317 ERROR [org.apache.hadoop.util.Shell] Failed to locate the winutils binary in the hadoop binary path
java.io.IOException: Could not locate executable D:\hadoop-1.2.0\bin\winutils.exe in the Hadoop binaries.
	at org.apache.hadoop.util.Shell.getQualifiedBinPath(Shell.java:278)
	at org.apache.hadoop.util.Shell.getWinUtilsPath(Shell.java:300)
	at org.apache.hadoop.util.Shell.<clinit>(Shell.java:293)
	at org.apache.hadoop.util.StringUtils.<clinit>(StringUtils.java:76)
	at org.apache.hadoop.conf.Configuration.getStrings(Configuration.java:1514)
	at org.apache.hadoop.hbase.zookeeper.ZKConfig.makeZKProps(ZKConfig.java:113)
	at org.apache.hadoop.hbase.zookeeper.ZKConfig.getZKQuorumServersString(ZKConfig.java:265)
	at org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher.<init>(ZooKeeperWatcher.java:159)
	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.HConnectionManager$HConnectionImplementation.getKeepAliveZooKeeperWatcher(HConnectionManager.java:1710)
	at org.apache.hadoop.hbase.client.ZooKeeperRegistry.getClusterId(ZooKeeperRegistry.java:82)
	at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.retrieveClusterId(HConnectionManager.java:806)
	at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.<init>(HConnectionManager.java:633)
	at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
	at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)
	at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27)
	at java.lang.reflect.Constructor.newInstance(Constructor.java:513)
	at org.apache.hadoop.hbase.client.HConnectionManager.createConnection(HConnectionManager.java:387)
	at org.apache.hadoop.hbase.client.HConnectionManager.createConnection(HConnectionManager.java:366)
	at org.apache.hadoop.hbase.client.HConnectionManager.getConnection(HConnectionManager.java:247)
	at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:188)
	at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:150)
	at com.dhgate.ywhbase.test.QueryTest.main(QueryTest.java:43)


从上面的异常中国就可以看出,散仙使用的底层hadoop是1.x的环境变量,故报此异常了,不过这个异常不影响数据读取,但是为了不影响美观,我们还是需要把它处理掉,解决方法如下:


(1),比较简单的解决办法,在客户端上下载一个hadoop2.2的压缩包,解压,并配置环境变量把HADOOP_HOME改成2.x的,可以在程序里,设定,也可以直接在windows上的我的电脑右击里设置。


(2),无须下载hadoop2.2的压缩包,直接在代码里,判断是否有无winutils.exe 这个windows下的可执行文件,如果没有的话,就自己创建,这样一来,就不需要改hadoop1.x的环境变量了。
代码如下:

Java代码 复制代码 收藏代码
  1. if (System.getProperty("os.name").contains("Windows")) {  
  2.             File workaround = new File(".");  
  3.             System.getProperties().put("hadoop.home.dir",workaround.getAbsolutePath());  
  4.             File dir = new File("./bin");  
  5.             if (!dir.exists()) {  
  6.                 dir.mkdirs();  
  7.             }  
  8.             File exe = new File("./bin/winutils.exe");  
  9.             if (!exe.exists()) {  
  10.                 exe.createNewFile();  
  11.             }  
  12.         }  
分享到:
评论

相关推荐

    hbase 的java代码 集合 hbase 0.96

    1. **连接HBase**:在Java代码中,我们使用`HBaseConfiguration.create()`来创建一个配置对象,然后可以设置各种配置参数,如Zookeeper的地址(`HBASE_ZOOKEEPER_QUORUM`),端口(`HBASE_ZOOKEEPER_CLIENT_PORT`)...

    如何使用Java API操作Hbase(基于0.96新的api)

    在Java中操作HBase,尤其是基于0.96版本的新API,涉及到许多核心概念和方法。HBase是一个分布式的、可扩展的列式数据库,它建立在Hadoop之上,适用于实时读写大数据。本篇文章将深入探讨如何使用Java API与HBase进行...

    hbase-0.96 jar包

    HBase 0.96是一个重要的里程碑,因为它在性能和稳定性上都有显著提升,特别是在处理大规模数据集时。 HBase设计的目标是提供实时读写访问,同时保持大数据量的水平扩展能力。它的核心特性包括: 1. **分布式存储**...

    java连接hbase的jar包

    HBase是一个分布式、版本化的NoSQL数据库,基于Google的Bigtable设计,运行在Hadoop之上,提供高可靠性、高性能的数据存储和检索服务。 在Java中连接HBase,首先需要在项目中引入相关的jar包。这些jar包通常包括...

    Hbase 官方中文文档

    HBase是一个开源的非关系型分布式数据库(NoSQL),它在Hadoop和Zookeeper的基础上提供高可靠性、高性能、列存储、可伸缩的分布式存储解决方案。以下是对文档内容的详细梳理: 1. 入门部分: - 介绍了HBase的基本...

    HBase 官方文档

    - **REST**:说明 HBase 的 REST API 接口及其使用方法。 - **Thrift**:解释 HBase 的 Thrift 接口,并给出示例。 - **C/C++ Apache HBase Client**:提供 C/C++ 开发者使用的 HBase 客户端接口。 #### 十二、...

    [APACHE]Apache Crunch - Getting Started.pdf

    Apache Crunch是一个用于简化在Apache Hadoop上创建数据管道过程的Java API。它的发展受到Google的FlumeJava API的影响,该API用于构建基于Google自身MapReduce实现的数据管道。Crunch提供了对MapReduce的薄层抽象,...

Global site tag (gtag.js) - Google Analytics