Unable to create ZooKeeper Connection

发布于 2022-09-11 23:38:00 字数 1860 浏览 14 评论 0

我使用HBase API试图创建一个Table,但是抛出了如下异常:
Unable to create ZooKeeper Connection
java.io.IOException: Couldn't instantiate org.apache.zookeeper.ClientCnxnSocketNIO

我的代码如下:

package GroupHBase.HBaseTest;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.log4j.spi.Configurator;
import org.junit.jupiter.api.Test;

public class PutTest {


static HBaseAdmin admin;
static String TableName="haha";


public static void init() throws Exception{
Configuration conf=new Configuration();
conf.set("hbase.zookeeper.quorum", "tuge2,tuge3,tuge4");
admin=new HBaseAdmin(conf);
}

@Test
public static void createTable() throws Exception {

HTableDescriptor desc=new HTableDescriptor(TableName.valueOf(TableName)); 
HColumnDescriptor cf=new HColumnDescriptor("cf".getBytes());
desc.addFamily(cf);
admin.createTable(desc);

}



public static void main(String[] args) throws IOException {
try {
init();
createTable();
System.out.println("zj...");
}
catch(Exception ex){
ex.printStackTrace();
}


}

}

我Hadoop和ZooKeeper里面的Jar包都引入了。
Hadoop版本是2.6.5
ZooKeeper版本是3.5.5
纠结了一天,刚开始使用的是官网的Demo,后来出现上述异常后搜的网上的Demo报了同样错误。 谁能帮帮我

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文