无法使用java连接到hbase?

vyswwuz2  于 2021-06-02  发布在  Hadoop
关注(0)|答案(1)|浏览(398)

在问这个问题之前,我搜索了很多来解决下面的问题,但没有解决,如果有人能在这方面提供帮助。
我已经安装了hadoop12.5.0和hbase 0.98.6(在伪dist模式下)。我正在尝试运行一个简单的java程序从hbase检索数据。我的所有节点都在运行。我的密码是-

Configuration conf = HBaseConfiguration.create();
conf.set("hbase.master","hadoopHost:60000");
conf.set("hbase.zookeeper.quorum", hBaseZookeeperHostName);
conf.set("hbase.zookeeper.property.clientPort", "2181");
System.out.println("hello");
HTableInterface table = HConnectionManager.createConnection(conf).getTable("user".getBytes());
System.out.println(table.getTableDescriptor().getColumnFamilies().toString());

它正在打印hello,之后会被卡住一段时间,结束时没有任何错误或警告。
我对这个大数据世界非常陌生,如果有人能花时间解决这个问题的话。

nfzehxib

nfzehxib1#

有两种方法可以为hbase连接创建配置。
我们可以使用类中的以下行创建连接,然后在类路径中设置hbase-site.xml。
configuration conf=hbaseconfiguration.create;htableinterface table=hconnectionmanager.createconnection(conf).gettable(“user”.getbytes());
这样,hbase-site.xml中定义的值将用于创建连接。
如果要重写hbase-site.xml中的值,可以从类路径中删除hbase-site.xml,并按照需要设置参数,如上面代码中所述。
既然您试图使用默认值,我建议您使用选项一。

相关问题