`
san_yun
  • 浏览: 2663280 次
  • 来自: 杭州
文章分类
社区版块
存档分类
最新评论

hbase client无法连接到本地hbase server

 
阅读更多

今天下午浪费了不少时间在搞本地hbase server测试,测试代码如下:

import java.io.IOException;

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.HTable;

public class MyHbaseTester {

	public static void main(String[] args) throws IOException {

		Configuration config = HBaseConfiguration.create();
		config.set("hbase.zookeeper.quorum", "localhost");
		config.set("hbase.zookeeper.property.clientPort", "2181");
		HBaseAdmin.checkHBaseAvailable(config);
		HTable table = new HTable(config, "mytable");
		System.out.println("Table testTable obtained!");

	}
}

 

一直报一些莫名其妙的错误:



 



 

后来发现原来是java client的版本和server的版本不对,修改正确的依赖版本,问题解决:

	<dependency>
	  <groupId>org.apache.hbase</groupId>
	  <artifactId>hbase</artifactId>
	  <version>0.94.2</version>
	</dependency>
	
	<dependency>
	  <groupId>org.apache.hadoop</groupId>
	  <artifactId>hadoop-core</artifactId>
	  <version>1.0.0</version>
	</dependency>

 

  • 大小: 237.6 KB
  • 大小: 258.3 KB
  • 大小: 237.7 KB
分享到:
评论

相关推荐

    java访问hbase所需的jar包

    例如,`org.apache.hadoop.hbase.client.Connection`接口用于创建到HBase集群的连接,`org.apache.hadoop.hbase.client.Table`接口则用于操作表对象。 其次,`hbase-common.jar`包含了HBase通用的功能,如数据序列...

    最新版linux hbase-2.3.2-client-bin.tar.gz

    通过`Configuration`类可以设置这些参数,并创建`Connection`对象,以连接到HBase集群。 2. 表操作:`Admin`接口提供了创建、删除、修改表的操作。例如,可以使用`createTable()`方法创建新的表,`disableTable()`...

    HBase_Client_Api_Guide

    HBASE_CONFIG.set("hbase.zookeeper.quorum", "zkServer"); HBASE_CONFIG.set("hbase.zookeeper.property.clientPort", "2181"); HBaseConfiguration cfg = new HBaseConfiguration(HBASE_CONFIG); } ``` **2.2 ...

    hbase- java开发连接工具类

    除了`hbase-client.jar`,可能还包含其他相关的JAR包,如`hbase-common.jar`,它包含了HBase的通用工具和模块,`hbase-server.jar`包含RegionServer所需的服务端代码,以及`hbase-protocol.jar`包含客户端和服务器...

    hbase jar包.zip

    接着,jackson-databind-2.12.4.jar是Jackson JSON库的数据绑定模块,它允许将JSON对象映射到Java对象,反之亦然,这对于HBase中的数据序列化和反序列化至关重要。同时,jackson-core-2.12.4.jar是Jackson库的基础...

    hadoop hbase 全jar包

    HBase的jar包则包含了HBase Server、HBase Client、Zookeeper等相关组件,使得开发者可以与HBase集群进行交互,执行CRUD(创建、读取、更新、删除)操作。 在实际使用中,开发者可能需要将这些jar包添加到类路径...

    最新版linux hbase-2.3.3-client-bin.tar.gz

    HBase客户端需要连接到HBase集群,这通常通过配置文件完成。在"hbase-2.3.3-client/conf"目录下,有一个名为"hbase-site.xml"的文件,这里可以设置诸如集群地址、端口、安全认证等参数。对于分布式环境,需要确保...

    java操作Hbase之从Hbase中读取数据写入hdfs中源码

    这段代码连接到HBase集群,然后从指定的表中读取一行数据。"zookeeper_server_ip"应替换为实际的Zookeeper服务器IP地址,"your_table_name"应替换为你要操作的HBase表名,"row_key"是你想要读取的行键。 接下来,...

    Hbase同步数据到Solr的方案

    1. 客户端(Client)对HBase执行Put或Delete操作。 2. 操作被记录在本地Region Server的WAL Log中。 3. Region Server将WAL Log中的变更事件复制到其他Slave Region Server。 4. Slave Region Server在接收到事件后...

    java从本地读文件并上传Hbase

    在Java编程环境中,将本地文件读取并上传到HBase是一项常见的任务,特别是在大数据处理和存储的场景下。HBase是一个分布式、版本化的NoSQL数据库,基于Apache Hadoop,适用于大规模数据存储。以下是一个详细的过程,...

    java链接hbase数据示例代码

    config.set("hbase.zookeeper.quorum", "zookeeper_server_address"); // 替换为你的Zookeeper服务器地址 ``` 为了执行CRUD操作,我们需要一个`Table`对象,它代表HBase中的表。以下是如何获取表的示例: ```java ...

    HBase技术介绍.docx

    - **Client**: 使用HBase RPC机制与HMaster和HRegionServer通信。 - **HMaster**: 负责整个集群的管理和协调工作,包括Region分配、负载均衡等。 - **HRegionServer**: 负责处理客户端的数据读写请求,每个Region ...

    java连接hbase的jar包

    Java连接HBase主要依赖于Apache HBase提供的Java客户端库,这个库包含了所有必要的类和接口,使得Java应用程序能够与HBase进行交互。HBase是一个分布式、版本化的NoSQL数据库,基于Google的Bigtable设计,运行在...

    hbase的rowkey设计与hbase的协处理器运用.docx

    2. 根据 hbase:meta 所在 RegionServer 的访问信息,客户端会将该元数据表加载到本地并进行缓存。 3. 根据数据所在 RegionServer 的访问信息,客户端会向该 RegionServer 发送真正的数据读取请求。 RegionServer 的...

    simple-hbase-client:简单的 HBase 客户端

    在实际应用中,优化HBase性能的关键包括合理的表设计(如选择合适的行键和列族)、批量操作、利用Region Server的本地性、以及使用合适的过滤器减少网络传输。此外,监控HBase的性能指标,如 Region Server负载、...

    Hbase

    在 HBase 中,客户端(如 `HbaseClient.java` 文件所示)是应用程序与 HBase 交互的接口。客户端通过连接到 ZooKeeper 获取 Master Server 的位置,然后与 RegionServer 进行通信,执行 CRUD(创建、读取、更新和...

    java链接及操作hbase实例代码

    在Java编程环境中,链接并操作HBase是一种常见的任务,特别是在大数据处理和分布式存储的应用场景下。...务必注意,根据你的HBase集群配置,可能需要调整代码中的连接参数,以确保正确连接到你的HBase实例。

    spark读取hbase数据,并使用spark sql保存到mysql

    Spark 提供了 `spark-hbase-connector` 库,允许我们方便地连接到 HBase 并进行数据操作。在 Scala 代码中,你需要先引入相应的依赖,例如在 `build.sbt` 或 `pom.xml` 文件中添加: ```scala libraryDependencies ...

    springboot集成phoenix+hbase

    接下来,我们需要配置Spring Boot应用以连接到HBase和Phoenix。这通常通过在`application.properties`文件中设置属性完成: ```properties spring.datasource.url=jdbc:phoenix:localhost:2181:/hbase spring....

    HBase源码分析

    HBaseClient是客户端的核心接口,它负责发起对HBase服务的各种操作,如put、get、delete等。当客户端执行put操作时,如示例所示,会创建一个HTable对象,然后通过HTable的put方法向指定表添加数据。这些put操作会被...

Global site tag (gtag.js) - Google Analytics