集群启动正常,hbase java api连接超时

2021-05-31 23:22:52,092 WARN  [ReadOnlyZKClient-Master:2181,Slave1:2181,Slave2:2181@0x03c153a1] zookeeper.ReadOnlyZKClient (ReadOnlyZKClient.java:exec(192)) - 0x03c153a1 to Master:2181,Slave1:2181,Slave2:2181 failed for get of /hbase/hbaseid, code = CONNECTIONLOSS, retries = 30
2021-05-31 23:22:53,103 INFO  [ReadOnlyZKClient-Master:2181,Slave1:2181,Slave2:2181@0x03c153a1-SendThread(Master:2181)] zookeeper.ClientCnxn (ClientCnxn.java:logStartConnect(1032)) - Opening socket connection to server Master/175.27.241.236:2181. Will not attempt to authenticate using SASL (unknown error)
2021-05-31 23:23:14,144 WARN  [ReadOnlyZKClient-Master:2181,Slave1:2181,Slave2:2181@0x03c153a1-SendThread(Master:2181)] zookeeper.ClientCnxn (ClientCnxn.java:run(1162)) - Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection timed out: no further information
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:715)
    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)

 

代码:

package hbasetest;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.filter.*;

public class conn {
    public static Configuration configuration;
    public static Connection connection;
    public static Admin admin;
    public static void main(String[] args){
        init();
    }    
    public static void init(){
        configuration = HBaseConfiguration.create();
        configuration.set("hbase.rootdir","hdfs://Master:9000/hbase");
        configuration.set("hbase.zookeeper.quorum","Master,Slave1,Slave2");
        configuration.set("hbase.zookeeper.property.clientPort","2181");
        try {
            connection = ConnectionFactory.createConnection(configuration);
            admin = connection.getAdmin();
            System.out.println("init success");
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        }
    }

}

可以参考这篇文章,希望对你有帮助:【已解决】java.net.ConnectException: Connection timed out: no further information_wzder-CSDN博客

您的问题已经有小伙伴解答了,请点击【采纳】按钮,采纳帮您提供解决思路的答案,给回答的人一些鼓励哦~~

ps:开通问答VIP,享受5次/月 有问必答服务,了解详情↓↓↓

【电脑端】戳>>>  https://vip.csdn.net/askvip?utm_source=1146287632
【APP 】  戳>>>  https://mall.csdn.net/item/52471?utm_source=1146287632