使用Java对hbase进行连接测试,连接不上,超时,

我在Linux上安装了hbase的单机版,hbase版本是1.2.6,
zookeeper使用的是hbase自己的,Linux防火墙开放了16010和2181端口,
使用hbase shell 可以正常操作hbase,浏览器也可以正常访问hbase,
但是我使用Java对hbase进行连接测试的时候就是一直连接不上,然后当我关闭
Linux防火墙的时候java又可以正常的对hbase进行连接访问了,???,这是怎么回事,是因为Linux防火墙还需要开放其他端口吗

0

2个回答

HBase客户端需要配置hosts文件为IP HBase所在服务器的主机名

 public static Configuration configuration;
    static {
        configuration = HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.property.clientPort", "2181");//2181默认;映射61000
        configuration.set("hbase.zookeeper.quorum", "ip");//默认
        configuration.set("hbase.master", "ip:16010");//hbase的0系列默认端口是60000;1系列默认端口16010
    }
0
qq_42687140
qq_42687140 关闭防火墙
大约一年之前 回复
weixin_38860401
可以简单点 linux和Windows的hosts文件我都已经配置了
大约一年之前 回复

9000端口也要关闭防火墙

0
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
Java连接HBase超时解决方法
通过java连接hbase时,报出超时的错误,如下: 2017-09-13 20:25:01,882 [main] WARN  org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where ap
zookeeper 超时连接不上
在本地虚拟机上安装完zookeeper之后,java代码测试发布服务,总是报:org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 5000 at org.I0Itec.zkclient.ZkClient.connect(ZkClient.jav...
java连接不上hbase无异常信息
一直卡在第26行也无报错信息 等了大概十分钟 xception in thread "main" org.apache.hadoop.hbase.client.RetriesExhaustedException: Failed after attempts=35, exceptions: Tue Sep 12 11:25:29 CST 2017, RpcRetryingCaller{glob
VS2015连接数据库,测试连接连接不上
[img=https://img-bbs.csdn.net/upload/201602/14/1455421741_183507.png][/img]有人知道这个问题吗?我第一次搞这个,我装了SQL SERVER2014
oracle 老连接能用,新连接连接不上超时
oracle 连接数设置为5000,用命令查看已使用的连接数才69rn现在的情况是:正在运行的程序(c3p0连接池)能正常使用,新启动的程序(另外的程序,同样的是c3p0)启动时获取不到数据库连接。rn并且PL/SQL 本身已经连接的没问题,如果新开PL/SQL就连接不上。rn此问题数据库运行一段时间就会出现,当然也不是固定时间段出现,偶尔,重启数据库服务器后又好了。rn求解 分不够,可以再加。
java client 连接hbase报错,超时
public static Configuration configuration; static { configuration = HBaseConfiguration.create(); configuration.set("hbase.zookeeper.property.clientPort", "2181"); configuration.set("hbase.zookeeper
Java 连接HBASE ,执行查询超时的解决方法
Hbase 的查询速度非常快,适合用于检索,但是,但待检索的数据量特别大的时候,很容易造成连接超时。通过修改java连接hbase的配置参数,可以有效解决这个问题。注意,单纯修改hbase的配置参数,如超时,并不会起作用。
Java项目连接hbase时超时
本人小白一枚,现在有个项目是用Java项目连接hbase。我用的是windows下的Java项目连接linux虚拟机上的hbase,hbase开启之后连接提示连接超时(ps:主机之间可互通),求助。。。nlog4j:WARN No appenders could be found for logger (org.apache.hadoop.util.Shell).nlog4j:WARN Please initialize the log4j system properly.nSLF4J: Class path contains multiple SLF4J bindings.nSLF4J: Found binding in [jar:file:/E:/apache-tomcat-7.0.85-windows-x64/apache-tomcat-7.0.85/webapps/car_hbase/WEB-INF/lib/slf4j-log4j12-1.5.8.jar!/org/slf4j/impl/StaticLoggerBinder.class]nSLF4J: Found binding in [jar:file:/E:/apache-tomcat-7.0.85-windows-x64/apache-tomcat-7.0.85/webapps/car_hbase/WEB-INF/lib/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class]nSLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.ne785dc9437424bf8a7714f460293896c HBASE表创建失败!njava.io.IOException: Failed to get result within timeout, timeout=60000msn at org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.call(ScannerCallableWithReplicas.java:232)n at org.apache.hadoop.hbase.client.ScannerCallableWithReplicas.call(ScannerCallableWithReplicas.java:58)n at org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithoutRetries(RpcRetryingCaller.java:219)n at org.apache.hadoop.hbase.client.ClientScanner.call(ClientScanner.java:277)n at org.apache.hadoop.hbase.client.ClientScanner.loadCache(ClientScanner.java:438)n at org.apache.hadoop.hbase.client.ClientScanner.next(ClientScanner.java:312)n at org.apache.hadoop.hbase.MetaTableAccessor.fullScan(MetaTableAccessor.java:604)n at org.apache.hadoop.hbase.MetaTableAccessor.tableExists(MetaTableAccessor.java:366)n at org.apache.hadoop.hbase.client.HBaseAdmin.tableExists(HBaseAdmin.java:410)n at org.apache.hadoop.hbase.client.HBaseAdmin.tableExists(HBaseAdmin.java:420)n at util.HBaseUtil.createTable(HBaseUtil.java:45)n at util.HbaseDemo.createTable(HbaseDemo.java:55)n at util.StartupListener.contextInitialized(StartupListener.java:31)n at org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:5118)n at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5641)n at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:145)n at org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:1015)n at org.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:991)n at org.apache.catalina.core.StandardHost.addChild(StandardHost.java:652)n at org.apache.catalina.startup.HostConfig.deployDirectory(HostConfig.java:1296)n at org.apache.catalina.startup.HostConfig$DeployDirectory.run(HostConfig.java:2038)n at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)n at java.util.concurrent.FutureTask.run(FutureTask.java:266)n at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)n at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)n at java.lang.Thread.run(Thread.java:745)
HBase的安装配置和使用Java连接
Hadoop集群搭建可参考:http://blog.csdn.net/yanhang0610/article/details/51896545 1        系统环境 系统:CentOS 7.0。 版本:JDK 1.8.0_91,Hadoop 2.7.3,Zookeeper 3.4.9,Hbase 1.2.5。 参考:https://wenku.baidu.com/view/b2bd9
使用ycsb对hbase进行测试出现问题
大家好,我的操作系统是suse Linux 2.6.32.12-0.7 ,jdk版本是1.7.0_55rn我从官网直接下载了[b]hbase-0.94.19.tar.gz[/b]与[b]ycsb-0.1.4.tar.gz[/b],直接通过tar -xvf对其进行解压,我修改了下hbase的[b]hbase-site.xml[/b]的内容如下rn[color=#FF0000]rnrn hbase.rootdirrn /root/dbData/hbaseDatarn rn[/color]rn之后就可以通过start-hbase.sh启动hbase,并能够使用,创建表之类rn然后我将hbase/lib下的所有都copy到ycsb-0.1.4/hbase-binding/lib/下,把hbase的hbase-site.xml也copy到ycsb-0.1.4/hbase-binding/conf/下面(唯一没替换的就是ycsb-0.1.4/hbase-binding/lib/下的 hbase-binding-0.1.4.jar,因为这个hbase里没有),然后通过rn[color=#33CCCC]./ycsb load hbase -P ../workloads/workloada -p threads=10 -p columnfamily=f1 -p recordcount=1000 -s > load.dat[/color]rn想进行测试,结果就报了如下错误:rn[code=java]rn14/03/11 22:54:31 INFO zookeeper.ZooKeeper: Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMTrn14/03/11 22:54:31 INFO zookeeper.ZooKeeper: Client environment:host.name=localhostrn14/03/11 22:54:31 INFO zookeeper.ZooKeeper: Client environment:java.version=1.7.0_55rn14/03/11 22:54:31 INFO zookeeper.ZooKeeper: Client environment:java.vendor=Oracle Corporationrn14/03/11 22:54:31 INFO zookeeper.ZooKeeper: Client environment:java.home=/usr/java/jdk1.7.0_55/jrern14/03/11 22:54:31 INFO zookeeper.ClientCnxn: Opening socket connection to server localhost/192.168.1.58:2181. Will not attempt to authenticate using SASL (unknown error)rn14/03/11 22:54:31 INFO zookeeper.ClientCnxn: Socket connection established to localhost/192.168.1.58:2181, initiating sessionrn14/03/11 22:54:31 INFO zookeeper.ClientCnxn: Session establishment complete on server localhost/192.168.1.58:2181, sessionid = 0x144b196e2f20005, negotiated timeout = 40000rnjava.lang.IllegalArgumentException: Not a host:port pair: ?rn4304@zeldazelda,36541,1394548863086rn at org.apache.hadoop.hbase.HServerAddress.(HServerAddress.java:60)rn at org.apache.hadoop.hbase.zookeeper.RootRegionTracker.dataToHServerAddress(RootRegionTracker.java:82)rn at org.apache.hadoop.hbase.zookeeper.RootRegionTracker.waitRootRegionLocation(RootRegionTracker.java:73)rn at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegion(HConnectionManager.java:786)rn at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegion(HConnectionManager.java:766)rn at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegionInMeta(HConnectionManager.java:895)rn at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegion(HConnectionManager.java:797)rn at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegion(HConnectionManager.java:766)rn at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegionInMeta(HConnectionManager.java:895)rn at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegion(HConnectionManager.java:801)rn at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegion(HConnectionManager.java:766)rn at org.apache.hadoop.hbase.client.HTable.(HTable.java:189)rn at org.apache.hadoop.hbase.client.HTable.(HTable.java:163)rn at com.yahoo.ycsb.db.HBaseClient.getHTable(HBaseClient.java:111)rn at com.yahoo.ycsb.db.HBaseClient.update(HBaseClient.java:295)rn at com.yahoo.ycsb.db.HBaseClient.insert(HBaseClient.java:350)rn at com.yahoo.ycsb.DBWrapper.insert(DBWrapper.java:145)rn at com.yahoo.ycsb.workloads.CoreWorkload.doInsert(CoreWorkload.java:461)rn at com.yahoo.ycsb.ClientThread.run(Client.java:269)rn[/code]rnrn在网上查了很多大楖是版本的问题,这个是哪个版本不对?rnrn我的hosts如下rn192.168.1.58 localhostrn192.168.1.58 zelda.site zeldarn192.168.1.58 zeldarnrn请大家帮帮忙,我这个应该如何调?新手很多不太懂,也是按网上的一些教程操作的rn
HBase之——连接不上Zookeeper的解决方案
转载请注明出处:https://blog.csdn.net/l1028386804/article/details/88695338 当HBase连不上Zookeeper时,会报出如下的错误信息: Could not start ZK at requested port of 2181. ZK was started at port: 2182. Aborting as clients ...
使用hbase的java api连接集群超时的问题
环境:hadoop2.6.0,hbase1.2.0 在windows环境下在eclipse中使用hbase Java api连接其他机器上的hbase报超时错误。后来移至Ubuntu环境下使用intelij idea连接hbase,发现除了本来报的超时错误,还报了unknown host:centos,原来是没做没做内网域名映射(我代码中是直接填的ip)。于是在ubuntu系统配置中加入此映射:
使用Xshell连接Linux连接不上
类似于这种形式: Could not connect to '192.168.1.101' (port 22): Connection failed. 有一种情况是,VMware中选择虚拟机的网络连接方式为NAT时,ping不到,将连接方式换成 桥接,且都在一个网段,这样就能连接成功了。 如我现在连接成功时Linux虚拟机的ip是192.168.1.101,windows主机的ip是192.1
java连接本地数据库,连接不上。、、、、
public class DatabaseOperation rnConnection conn= null; rn/** rn* rn* 取得当前数据库的连接 rn* rn* @param connHostName 主机名称或IP Address rn* @param connPort 连接数据库端口 rn* @param dbDBAUserName 连接数据库DBA用户名 rn* @param dbDBAPassword 连接数据库DBA用户密码 rn* @return rn*/ rnpublic Connection connectDatabase(String connHostName,String connPort,String dbDBAUserName,String dbDBAPassword) rnrntry rnClass.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver").newInstance(); rn String url = "jdbc:sqlserver://" + connHostName + ":" + connPort + ";DatabaseName=master"; rn conn = DriverManager.getConnection(url, dbDBAUserName, dbDBAPassword); rn rn setConn(conn); rncatch (Exception ex) rnex.printStackTrace(); rnsetConn(null); rn rnreturn getConn(); rn rnrnrnrnrnmain方法 rnrnpublic static void main(String[] args) rnDatabaseOperation db = new DatabaseOperation(); rnSystem.out.println("============"+ db.connectDatabase("localhost", "1433", "sa", "123456"));; rn rnrn端口是1433 rn驱动的包没有错,因为可以连接别人的数据库、 rnrnrn报错如下: rncom.microsoft.sqlserver.jdbc.SQLServerException: 到主机 的 TCP/IP 连接失败。 java.net.ConnectException: Connection refused: connect rnat com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDriverError(Unknown Source) rnat com.microsoft.sqlserver.jdbc.SQLServerConnection.connectHelper(Unknown Source) rnat com.microsoft.sqlserver.jdbc.SQLServerConnection.loginWithoutFailover(Unknown Source) rnat com.microsoft.sqlserver.jdbc.SQLServerConnection.connect(Unknown Source) rnat com.microsoft.sqlserver.jdbc.SQLServerDriver.connect(Unknown Source) rnat java.sql.DriverManager.getConnection(DriverManager.java:582) rnat java.sql.DriverManager.getConnection(DriverManager.java:185) rnat org.com.sap.db.DatabaseOperation.connectDatabase(DatabaseOperation.java:55) rnat org.com.sap.db.DatabaseOperation.main(DatabaseOperation.java:229) rn============null rnrnrn没有高人知道、、指点一二 rnrnrn“Connection refused: connect rncom.microsoft.sqlserver.jdbc.SQLServerException: 到主机 的 TCP/IP 连接失败。 java.net.ConnectException: Connection refused: connect rnat com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDriverError(Unknown Source) rnat com.microsoft.sqlserver.jdbc.SQLServerConnection.connectHelper(Unknown Source) rnat com.microsoft.sqlserver.jdbc.SQLServerConnection.loginWithoutFailover(Unknown Source) rnat com.microsoft.sqlserver.jdbc.SQLServerConnection.connect(Unknown Source) rnat com.microsoft.sqlserver.jdbc.SQLServerDriver.connect(Unknown Source) rnat java.sql.DriverManager.getConnection(Unknown Source) rnrnjava 连sql2005出现这个错误时,首先检查是否引用了sql 2005的包; rn第二步,看你的sql 2005是否开启了远程访问权限,具体设置如下: rnrnrn进入“Microsoft SQL Server 2005 ”——“配置工具”——“SQL Server 外围应用配置器” rnrn在进入“MSSQLSERVER"——“DATABASE" Engine”——“远程连接” rnrn选择“本地连接和远程连接(R)"——”同时使用tcp/ip和named pipes(B)" rnrn最后重启sql server 2005 ” rnrnrnrnrn试过了,不是这个问题。。。
hbase连接测试时的常见错误
hbase连接,常见错误 java.lang.NoClassDefFoundError: org/apache/htrace/Trace java.lang.NoClassDefFoundError: com/yammer/metrics/core/Gauge NoSuchMethodError: org.apache.hadoop.hbase.HTableDescriptor.addFamily
IIS+asp连接access连接不上,说服务器超时?
错误类型:rnActive Server Pages, ASP 0113 (0x80004005)rn超过了脚本运行的最长时间。可以为 Server.ScriptTimeOut 属性指定新值或更改 IIS 管理工具中的相应值来更改此限制。rn/testuser.asprnrnrn望大家指点,,分数给的 很高的 ~~急死了 `~是不是要什么配置啊~~/?
Hbase的客户端连接及使用
package cn.edu360.hbase.demo; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HColumnDescri...
java连接hbase优化
在使用java连接hbase的时候,首次初始化配置的时间大概是10s左右,所以会造成一些操作比较耗时,会自动断开连接。出错的环境如下,要实现一个订单的评论功能,评论有文件内容和图片,在后台首先要判断该用户的信息是否正确,然后才可以继续执行下一步的评论操作;所以这时候使用到mysql数据库。 用户信息正确之后,接下来就是执行图片的存储,这里使用到了hbase分布式数据库,在存储数据到hbase之前
java连接HBase(MAVEN项目)
一.若HBase在windows上: 在MAVEN官网找到 Apache HBase Testing Util,点击进去,选择版本号,在pom中导入依赖: <!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-testing-util --> <dependency> <groupId&g...
使用Phoenix连接Hbase
想要使用SQL语句对Hbase进行查询,需要使用Apache的开源框架Phoenix。 演示环境:Phoenix 4.9.0-Hbase-1.1 + Hbase 1.1.91 本地安装Phoenix1.1 下载Phoenix从Apache下载Phoenix(下载链接),从4.8.0到4.10.0各版本都有,本地安装的Hbase版本为1.1.9,所以选择对应Hbase是1.1版本的下载。这里我下载的
Java 连接hbase 进行简单操作
package com.paic.mario.service.impl; import java.io.File; import java.io.FileOutputStream; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbas
java连接mongodb超时
这个问题困扰我一天了,mongodb已经连接了就是不行插入不进去数据,一执行插入的时候就会报连接超时rnMongoClient mClient = new MongoClient("dds-2ze4c67d85f827b41.mongodb.rds.aliyuncs.com",3717);rn MongoDatabase db = mClient.getDatabase("root"); //数据库用户名rn System.out.println(db.getName());rn System.out.println("1");rnrn //得到集合,这里取"text"rn MongoCollection doc = db.getCollection("test"); //相当于表一个集合rn System.out.println(doc.getDocumentClass());rn System.out.println("2");rn //插入一个documentrn doc.insertOne(new Document("name","张三")); //执行到这里就失败rn rn System.out.println("3");rn rn rn rn rn 错误log日志rn 九月 26, 2017 5:55:28 下午 com.mongodb.diagnostics.logging.JULLogger logrn信息: Cluster created with settings hosts=[dds-2ze4c67d85f827b41.mongodb.rds.aliyuncs.com:3717], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms', maxWaitQueueSize=500rnrootrn1rnclass org.bson.Documentrn2rn九月 26, 2017 5:55:29 下午 com.mongodb.diagnostics.logging.JULLogger logrn信息: No server chosen by WritableServerSelector from cluster description ClusterDescriptiontype=UNKNOWN, connectionMode=SINGLE, serverDescriptions=[ServerDescriptionaddress=dds-2ze4c67d85f827b41.mongodb.rds.aliyuncs.com:3717, type=UNKNOWN, state=CONNECTING]. Waiting for 30000 ms before timing outrn九月 26, 2017 5:55:49 下午 com.mongodb.diagnostics.logging.JULLogger logrn信息: Exception in monitor thread while connecting to server dds-2ze4c67d85f827b41.mongodb.rds.aliyuncs.com:3717rncom.mongodb.MongoSocketOpenException: Exception opening socketrn at com.mongodb.connection.SocketStream.open(SocketStream.java:63)rn at com.mongodb.connection.InternalStreamConnection.open(InternalStreamConnection.java:115)rn at com.mongodb.connection.DefaultServerMonitor$ServerMonitorRunnable.run(DefaultServerMonitor.java:116)rn at java.lang.Thread.run(Unknown Source)rnCaused by: java.net.SocketTimeoutException: connect timed outrn at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)rn at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)rn at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)rn at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)rn at java.net.AbstractPlainSocketImpl.connect(Unknown Source)rn at java.net.PlainSocketImpl.connect(Unknown Source)rn at java.net.SocksSocketImpl.connect(Unknown Source)rn at java.net.Socket.connect(Unknown Source)rn at com.mongodb.connection.SocketStreamHelper.initialize(SocketStreamHelper.java:50)rn at com.mongodb.connection.SocketStream.open(SocketStream.java:58)rn ... 3 morernrnException in thread "main" com.mongodb.MongoTimeoutException: Timed out after 30000 ms while waiting for a server that matches WritableServerSelector. Client view of cluster state is type=UNKNOWN, servers=[address=dds-2ze4c67d85f827b41.mongodb.rds.aliyuncs.com:3717, type=UNKNOWN, state=CONNECTING, exception=com.mongodb.MongoSocketOpenException: Exception opening socket, caused by java.net.SocketTimeoutException: connect timed out]rn at com.mongodb.connection.BaseCluster.createTimeoutException(BaseCluster.java:375)rn at com.mongodb.connection.BaseCluster.selectServer(BaseCluster.java:104)rn at com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.(ClusterBinding.java:75)rn at com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.(ClusterBinding.java:71)rn at com.mongodb.binding.ClusterBinding.getWriteConnectionSource(ClusterBinding.java:68)rn at com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:221)rn at com.mongodb.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:169)rn at com.mongodb.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:75)rn at com.mongodb.Mongo.execute(Mongo.java:827)rn at com.mongodb.Mongo$2.execute(Mongo.java:810)rn at com.mongodb.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:515)rn at com.mongodb.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:306)rn at com.mongodb.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:297)rn at com.yingyan.jdbc.mongodb.main(mongodb.java:99)rn
Python 使用 Thrift 连接 HBASE 进行操作
在工作中想要使用Python对HBASE进行操作,主要用来获取数据进行分析,HBASE提供了 Thrift 借口,通过查看API 进行了一些的尝试,下面就是使用Python的相关代码,在使用之前需要启动 HBASE的Thrift和安装python的几个模块,在代码一开始的部分已经注明。使用的 Python 2.7API:https://wiki.apache.org/hadoop/Hbase/Th...
java 连接HBase客户端
连接HBase客户端 1. 创建一个新的maven项目,导入org.apache.hadoop等jar包 连接Hbase客户端 并查询数据。 package com.hbase;import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apac
java连接hbase的jar包
java连接hbase的jar包,java连接hbase的jar包,java连接hbase的jar包,java连接hbase的jar包
java连接Hbase数据库
当前工作中遇到一个场景,我们提供接口服务被其它系统调用.调用比较频繁,需要将调用数据库保存起来,以备以后数据分析使用. 中间碰到了很多坑,最终实现了通过java来实现操作HBASE数据库.直接贴代码吧. 一.代码 先列出最终代码吧.然后在记录下填坑的过程(开发工程为gradle,为通用性转成maven本代码为精简后的代码,实际中比这复杂,所以其中部分问题是实际工程中碰到的). 1.1 pom.xml中的依赖 <dependencies> <dependency>
Java API连接HBase 进行增删查改操作
准备工作 连接hbase 创建表 添加数据 删除数据 更新数据 修改数据 删除表
java连接hbasejar包
java连接hbase需要的jar包!欢迎下载!
java连接本机hbase
在ide工具里我们喜欢用maven解决依赖的问题,但 java hbase连接本机hbase服务,只能在项目中引入hbase\lib,我原来用maven的依赖,是各种报错。顺手漂了个简单例子package com.peidw.hbase; import java.io.IOException; import java.util.ArrayList; import java.util.List; ...
Java连接hbase获取数据
以下代码是同一个服务连接两个不同的hbase集群获取数据 1、pom文件 &amp;lt;project xmlns=&quot;http://maven.apache.org/POM/4.0.0&quot; xmlns:xsi=&quot;http://www.w3.org/2001/XMLSchema-instance&quot; xsi:schemaLocation=&quot;http://maven.apache.org/POM/4.0...
Java连接HBase失败
Hadoop 1.1.0、HBase-0.96.0。都安装在一台机器上。都能正常启动。rnHBase能用hbase shell进行数据库的增删改查操作。现在用java访问,报如下错:rn[code=text]rnorg.apache.hadoop.hbase.client.RetriesExhaustedException: Failed after attempts=35, exceptions:rnThu Jan 02 15:07:34 CST 2014, org.apache.hadoop.hbase.client.RpcRetryingCaller@1b118c5, java.net.ConnectException: Connection refused: no further informationrn[/code]rnrnjava代码如下rn[code=java]rnConfiguration conf = HBaseConfiguration.create();rn conf.set("hbase.zookeeper.quorum", "服务器IP");rn conf.set("hbase.zookeeper.property.clientPort", "2181");rn System.out.println("1111");rn HBaseAdmin admin = new HBaseAdmin(conf);rn System.out.println("2222");rn HTableDescriptor tableDescriptor = admin.getTableDescriptor(Bytes.toBytes("scores"));rn System.out.println("3333");rn byte[] name = tableDescriptor.getName();rn System.out.println("下面开始输出结果:");rn System.out.println("表名:" + new String(name));rn HColumnDescriptor[] columnFamilies = tableDescriptor.getColumnFamilies();rn for (HColumnDescriptor d : columnFamilies)rn rn System.out.println("列族名:" + d.getNameAsString());rn rn[/code]
hbase连接java
Java Hbase jar api hbase-0.20.6.jar hadoop-core-0.20.1.jar commons-logging-1.1.1.jar zookeeper-3.3.0.jar log4j-1.2.91.jar commons-codec-1.4.jar
Java连接HBase问题
我用windows上的maven工程连接虚拟机上的hbase时报错rnException in thread "main" org.apache.hadoop.hbase.client.RetriesExhaustedException: Can't get the locationsrn看网上有人说这个问题是配置问题 我已经把HBase集群的主机名和ip都加到hosts里面了 还是没有作用 以下是hbase-site 和core-site的配置 跪求大神帮忙啊rn[img=https://img-bbs.csdn.net/upload/201705/16/1494901713_3315.png][/img][img=https://img-bbs.csdn.net/upload/201705/16/1494901720_477858.png][/img]rnrn
java串口编程连接不上
package test;rnrnimport java.util.Enumeration;rnrnimport javax.comm.CommPortIdentifier;rnrnpublic class CommTest rn static CommPortIdentifier portId;rn static Enumeration portList;rn static int bauds[]=9600,19200,57600,115200;rn rn public static void main(String[] args) rn portList=CommPortIdentifier.getPortIdentifiers();rn System.out.println("端口连接测试");rn while (portList.hasMoreElements()) rn rn portId = (CommPortIdentifier) portList.nextElement(); rn if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) rn rn System.out.println("找到串口: " + portId.getName()); rn rn rnrn rnrn我都按照所说的配置将win32com.dll,comm.jar,javax.comm.properties放到了制定的jdk目录下。可是portList.hasMoreElements()) 的值一直是false。不知道是不是我配置那里有问题。求有经验的大神指教
java连接不上access数据库
一、运行程序后报告如下2个异常:rn 异常一表示未发现数据源名称并且未指定默认驱动程序;rn java.sql.SQLException: [Microsoft][ODBC Microsoft Access Driver][ODBC驱动程序管理器]rn 异常二是DSN名设置或驱动程序错误。rn java.lang.NullPointerExceptionrnrn二、数据库建立说明:rn 1)在Access中建立名为student数据库,数据库文件名student.mdb,表名STUDENT;rn 2)在控制面板->管理工具->ODBC数据源->系统DSN->添加->创建新数据源->rn 选择Microsoft Access Driver(*.mdb),确定->ODBC MicrosoftAccess安装->rn 数据源名文本框中输入student->在本地文件系统中选择数据库文件,确定。rnrn三、环境rn NetBeans;mssqlserver.jar、msutil.jar、msbase已经安装到工程lib文件夹中;rn 关于access驱动,安装AccessDatabaseEngine。rn (http://www.microsoft.com/en-us/download/details.aspx?id=13255)rnrn是没有连接上数据库还是什么问题导致的那两条异常?rn应该怎么排除?rnrn试验程序如下:(多谢)rnimport java.sql.*;rn/**rn *rn * @author leorn */rnpublic class JDBCODBCDemo rn private String dbURL;rn private String user;rn private String password;rn public static void main(String[] args)rn tryrn JDBCODBCDemo bridge = new JDBCODBCDemo();rn bridge.setURL("jdbc:odbc:student");rn bridge.setUser("");rn bridge.setPassword("");rn Connection con = bridge.getConnection();rn System.out.println(con.getCatalog());rn con.close();rn rn catch(Exception e)rn System.out.println(e.toString());rn rn rn public Connection getConnection()rn tryrn Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");rn return DriverManager.getConnection(dbURL,user,password);rn catch(Exception e)rn System.out.println(e.toString());rn rn return null;rn rn public void setURL(String dbURL)rn this.dbURL = dbURL;rn rn rn public void setUser(String user)rn this.user = user;rn rnrn public void setPassword(String password)rn this.password = password;rn rnrn
使用java连接redis测试
首先安装好redis之后 redis是不予许远程连接的,所以我们要设置一下 直接启动服务,设置redis的连接密码 ./bin/redis-server ./redis.conf ./bin/redis-cli config set requirepass 123456 然后使用maven项目测试 在pom.xml文件添加jedis &lt;dependency&gt; ...
Hbase错误总结:Hbase连接不上Zookeeper
错误信息: Could not start ZK at requested port of 2181. ZK was started at port: 2182. Aborting as clients (e.g. shell) will not be able to find this ZK quorum 2018-10-24 17:41:57,609 INFO [Thread-2] s...
客户端NET8测试连接不上
服务端的 监听配置,本地网络服务名配置都已经弄好rn监听和服务程序都已经启动起来了rn客户端的本地网络服务名配置也弄好rn在客户端上测试时连接不成功,提示出错:rn正在连接...ORA-12535: TNS: 操作超时
【python 连接hbase】python连接hbase 简单
python是通过thrift去访问操作hbase 1、首先需要先安装happyhbase和thrift pip install happybase pip install thrift 2、需要修改源码一个文件parser.py 如果执行的时候报错: py.parser.exc.ThriftParserError: ThriftPy does not support generati...
使用Java API连接和操作HBase数据库
创建的数据库存储如下数据 表结构 java代码 public class HbaseTest { /** * 配置ss */ static Configuration config = null; private Connection connection = null; private Table table = nul...