Leave a Comment
...... 380 [main] INFO zookeeper.ZooKeeper - Initiating client connection, connectString=hdp1.dg:2181 sessionTimeout=180000 watcher=hconnection 431 [main-SendThread()] INFO zookeeper.ClientCnxn - Opening socket connection to server hdp1.dg/192.168.6.228:2181 441 [main] INFO zookeeper.RecoverableZooKeeper - The identifier of this process is 12009@hdp1.dg 453 [main-SendThread(hdp1.dg:2181)] INFO zookeeper.ClientCnxn - Socket connection established to hdp1.dg/192.168.6.228:2181, initiating session 477 [main-SendThread(hdp1.dg:2181)] INFO zookeeper.ClientCnxn - Session establishment complete on server hdp1.dg/192.168.6.228:2181, sessionid = 0x15927cd88360099, negotiated timeout = 40000 Exception in thread "main" java.lang.IllegalArgumentException: Not a host:port pair: PBUF hdp1.dg�}¾�̫+�} at org.apache.hadoop.hbase.util.Addressing.parseHostname(Addressing.java:60) at org.apache.hadoop.hbase.ServerName.(ServerName.java:101) at org.apache.hadoop.hbase.ServerName.parseVersionedServerName(ServerName.java:283) at org.apache.hadoop.hbase.MasterAddressTracker.bytesToServerName(MasterAddressTracker.java:77) at org.apache.hadoop.hbase.MasterAddressTracker.getMasterAddress(MasterAddressTracker.java:61) at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.getMaster(HConnectionManager.java:667) at org.apache.hadoop.hbase.client.HBaseAdmin.(HBaseAdmin.java:121) at hbaseTest.main(hbaseTest.java:32)
I’ve seen “not a host:port pair” when using 0.90.2 client to talk to 0.92 server. Can you verify that your client and server HBase versions are the same, and what are they?
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.MasterNotRunningException; import org.apache.hadoop.hbase.client.HBaseAdmin; import java.io.IOException; /** * Created by shiyanghuang on 17/3/9. */ public class hbaseTest { public static final String HBASE_CONFIGURATION_ZOOKEEPER_QUORUM = "hbase.zookeeper.quorum"; public static final String HBASE_CONFIGURATION_ZOOKEEPER_CLIENTPORT = "hbase.zookeeper.property.clientPort"; public static void main(String[] args) { String hbaseZookeeperQuorum="hdp1.dg"; int hbaseZookeeperClientPort=2181; Configuration conf = new Configuration(); Configuration hConf = HBaseConfiguration.create(conf); hConf.set(HBASE_CONFIGURATION_ZOOKEEPER_QUORUM, hbaseZookeeperQuorum); hConf.setInt(HBASE_CONFIGURATION_ZOOKEEPER_CLIENTPORT, hbaseZookeeperClientPort); hConf.set("zookeeper.znode.parent", "/hbase-unsecure"); try { System.out.print("Start"); HBaseAdmin admin = null; System.out.print("Initialized"); try { admin = new HBaseAdmin(hConf); System.out.println("Get admin"); System.out.println(admin.listTableNames()); } catch (MasterNotRunningException e) { System.out.print("HBase is down"); } } catch (IOException e) { e.printStackTrace(); } } }