diff --git a/src/main/java/EmpHBaseClient.java b/src/main/java/EmpHBaseClient.java index bc4ca7d..1862b21 100644 --- a/src/main/java/EmpHBaseClient.java +++ b/src/main/java/EmpHBaseClient.java @@ -39,6 +39,12 @@ public class EmpHBaseClient { public EmpHBaseClient() { conf = HBaseConfiguration.create(); conf.set("hbase.zookeeper.quorum", "localhost"); + // 新增ZooKeeper端口配置(默认2181但显式声明更可靠) + conf.set("hbase.zookeeper.property.clientPort", "2181"); + // 新增重试策略配置(解决临时连接问题) + conf.set("hbase.client.retries.number", "3"); + conf.set("hbase.rpc.timeout", "60000"); + try { connection = ConnectionFactory.createConnection(conf); table = connection.getTable(TableName.valueOf("emp1520"));