在Java连接hbase时出现的问题

2024-04-02 02:59:00

问题1：

java.net.ConnectException: Connection refused: no further information

zookeeper.ClientCnxn: Session 0x0 for server null
- zookeeper未启动，或无法连接，从查看各节点zookeeper启动状态、端口占用、防火墙等方面查看原因。

问题2：

找不到zookeeper服务器，则需要在windows本地的C:\Windows\System32\drivers\etc\下的hosts文件中添加zookeeper集群的映射。　

问题3：

在最初的时候，我们设计的模式是拿出每天的股票信息，以股票名作为表名，然后每天遍历爬虫爬取到的股票信息，逐一添加到各个表中，结果在我执行了代码以后，每次都是程序执行到了插入第300条股票信息，也就是在往第三个表中插入数据的时候，程序就会卡死，接下来就会一直提示信息INFO [main] client.AsyncProcess: #2, waiting for some tasks to finish. Expected max=0, tasksInProgress=35。强制结束后再次运行就会报错，后来发现在/hbase/hbase-common/src/main/resources/hbase-default.xml中有这么一条配置信息

就是说我的代码连接数过大引起的问题。当然，与此同时集群也出现了问题，hdfs文件系统中的/hbase文件夹出现了损坏，于是我删掉重新建了一个，重启服务之后集群恢复正常。之后我们重新讨论了一下，设计了一下hbase中的表的模式，我们决定将所有股票信息插入在一张表中，问题从侧面得到了解决。

问题4：

最终显示页面读取数据的时候发现传入的数据是乱码

　　解决：代码中涉及到的全部的编码全是utf-8，在页面输入时的数据传入java查询类中时　　

String str  = new String(stocknum.getBytes("UTF-8"), "ISO-8859-1");

转载于:https://www.cnblogs.com/Try-kevin/p/7901302.html

在Java连接hbase时出现的问题相关推荐

java连接hbase时出现....is accessible from more than one module:
今天在用java程序连接hbase时,出现错误,The package org.apache.hadoop.hbase is accessible from more than one module: ...
java连接Hbase数据库
java连接Hbase数据库如果是是连接机群上的Hbase服务,需要提前将相关的几个xml文件存放在本地的编程目录下,否则开发端无法获取机群信息及授权: hdfs-site.xml core-sit ...
JAVA连接hbase伪分布失败_hbase伪分布安装配置
hbase.rootdir --hbase持久保存的目录 hdfs:192.168.8.101:9000/hbase hbase.cluster.distributed --是否是分布式 true h ...
Java连接HBASE数据库，创建一个表，删除一张表，修改表，输出插入，修改，数据删除，数据获取，显示表信息，过滤查询，分页查询，地理hash
准备工作 1.创建Java的Maven项目创建好的目录结构如下: 另外注意junit的版本,最好不要太高,最开始笔者使用的junit4.12的,发现运行的时候会报错.最后把Junit的版本改成4.7 ...
【mysql基础知识】解决java连接mysql时将localhost改为本机的ip地址后失败问题
查了很多资料,终于找到了原因. 需要修改mysql的权限. 转载自:https://blog.csdn.net/daicaho/article/details/81156855 ----------- ...
JDBC——java连接mysql、hive、hbase教程
JDBC模板一.准备工作 1.1.创建Maven工程 1.2.修改pom文件 1.3.修改Project Structure 1.4.修改Settings 1.5.资源文件夹二.Java连接mys ...
hbase原理与实践_JAVA连接HBase客户端及HBase写入数据和读取数据原理解析
JAVA连接HBase客户端接着上篇文章进行代码的实践,从JAVA 客户端对 HBase的客户端进行一系列操作工具类:HbaseUtil 静态代码块一次性创建连接对象并赋值返回连接对象 Con ...
java连接sqlserver2008
java连接sqlserver2008时应有sqljdbc4.jar驱动包.连接的示例代码如下: import java.sql.*;public class ConnectSQL {public s ...
java连接mysql的驱动包的下载
文章目录一.下载地址二.下载步骤 java连接mysql时需要驱动包,这个驱动包是一个jar库文件.java项目需要连接mysql时,需要把这个jar库文件导入. 一.下载地址下载地址: htt ...

最新文章

热门文章