今天下午浪费了不少时间在搞本地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>
相关推荐
Dive into advanced usage, such extended client and server options Learn cluster sizing, tuning, and monitoring best practices Design schemas, copy tables, import bulk data, decommission nodes, and ...
Find out how the communication between the client and server happens in HBase Grasp when to use and avoid MapReduce and how to perform various tasks with it Get to know the concepts of scaling with ...
Dive into advanced usage, such extended client and server options Learn cluster sizing, tuning, and monitoring best practices Design schemas, copy tables, import bulk data, decommission nodes, and ...
HBase数据读取流程解析-1——Client-Server交互逻辑.pdf 学习资料 复习资料 教学资源
- [ ] socket server接收到返回的数据后,分别写入到hbase数据库和kafka队列中 - [ ] 最后调用websocket server,往所有跟它建立的客户端发送接收到的数据 ## 项目备注 1、该资源内项目代码都经过测试运行成功,功能...
hbase-server 1.3.1 org.apache.hbase hbase-client 1.3.1 jdk.tools jdk.tools 1.8 system ${JAVA_HOME}/lib/tools.jar 6.2 HBaseAPI 6.2.1 获取Configuration对象 public static Configuration conf; ...
包括服务器端(Server)和客户端(Client) Server运行环境:Hadoop+HBase+Tomcat Client运行环境: Eclipse+Android Server端介绍: 接收客户端请求的Action: 添加短信Action----------->AddInfoAction.java 获取...
包括服务器端(Server)和客户端(Client) Server运行环境:Hadoop+HBase+Tomcat Client运行环境: Eclipse+Android Server端介绍: 接收客户端请求的Action: 添加短信Action----------->AddInfoAction.java 获取...
java.lang.RuntimeException: org.apache.hadoop.hbase.client.RetriesExhaustedException: Failed after attempts=36, exceptions: Fri Feb 14 10:30:36 CST 2020, null, java.net.SocketTimeoutException: ...
用于操作 HBase 区域的 Javascript。 该项目由 Denaux Robin 和 Paquet Kévin 制作,由 Fondement Frédéric 管理 安装 在执行任何命令之前,请注意您的计算机上必须安装 你需要的所有依赖都在项目中指定,你只...
#Client client使用OpenCV抓取摄像头数据,按照一定的时间,捕捉每帧图像,将图像数据重新编码后按照JSON格式通过kafka发送到Server上 #Server Spark Streaming实时接收来自kafka的多客户端的图像数据,并对数据做...
#Client client使用OpenCV抓取摄像头数据,按照一定的时间,捕捉每帧图像,将图像数据重新编码后按照JSON格式通过kafka发送到Server上 Spark Streaming实时接收来自kafka的多客户端的图像数据,并对数据做以下处理...
同时也可以将数据从关系型数据库或者⽂件 服务器导⼊到FusionInsight HD的HDFS/HBase中,或者反过来从HDFS/HBase导出到关系型数据库或者⽂件服务器中。同时提供 REST API接⼝,供第三⽅调度平台调⽤。 Loader模型...
/usr/hdp/current/phoenix-client/bin/psql.py zk_server:2181:/hbase-unsecure ddl/quotes.ddl /usr/hdp/current/phoenix-client/bin/psql.py zk_server:2181:/hbase-unsecure ddl/orders.ddl 运行拓扑 storm jar ...
2、全局数据一致:每个server保存一份相同的数据副本,client无论连接到哪个server,数据都是一致的 3、分布式读写,更新请求转发,由leader实施 4、更新请求顺序进行,来自同一个client的更新请求按其发送顺序...