2016-09-30 3 views
0
public class HbaseConnectorClass { 

private HTable table; 
private static final Logger log = LoggerFactory.getLogger(HbaseConnectorClass.class); 

public static void main(String[] args) throws Exception { 

    System.out.println("trying to connect ......"); 
    Configuration conf = HBaseConfiguration.create(); 

    conf.set("hbase.zookeeper.quorum", "localhost"); 
    conf.set("hbase.zookeeper.property.clientPort", "2222"); 
    conf.set("hbase.master", "localhost:60000");   

    try 
    { 
     System.out.println("Hbase is running!"); 
     HTable table = new HTable(conf,"personal"); 
     Put put = new Put(Bytes.toBytes("doe-john-m-12345")); 
     put.add(Bytes.toBytes("personal"), Bytes.toBytes("givenName"), Bytes.toBytes("John")); 
     put.add(Bytes.toBytes("personal"), Bytes.toBytes("mi"), Bytes.toBytes("M")); 
     put.add(Bytes.toBytes("personal"), Bytes.toBytes("surame"), Bytes.toBytes("Doe")); 
     put.add(Bytes.toBytes("contactinfo"), Bytes.toBytes("email"), Bytes.toBytes("[email protected]gmail.com")); 
     table.put(put); 
     table.flushCommits(); 
     table.close(); 

     System.out.println("Table created"); 
    } 
    catch(Exception ex) 
    { 
     ex.printStackTrace(); 
    } 
} 
} 

例外を使用してのHBaseを接続中:ていない ホスト:ポートペア:PBUFのHadoopのを} *} org.apache.hadoop.hbase.util.Addressing.parseHostname(Addressing.java:60) (org.apache.hadoop.hbase.ServerName)(ServerName.java:96) org.apache.hadoop.hbase .ServerName.parseVersionedServerName(ServerName.java:278) at org.apache.hadoop.hbase.MasterAddressTracker.bytesToServerName(MasterAddressTracker.java:77) at org.apache.hadoop.hbase.MasterAddressTracker.getMaste org.apache.hadoop.hbase.client.HBaseAdminで org.apache.hadoop.hbase.client.HConnectionManager $ HConnectionImplementation.getMaster(HConnectionManager.java:631) でrAddress(MasterAddressTracker.java:61) 。(HBaseAdmin .java:106) com.networkfleet.hbase.practice.HbaseConnectorClass.main(HbaseConnectorClass.java:63)ていないホスト:ポートスレッドのJavaを "メイン" java.lang.IllegalArgumentExceptionが

で com.networkfleet.hbase.practice.HbaseConnectorClass.creatTable(HbaseConnectorClass.java:82)で
+0

https://stackoverflow.com/questions/11649824/hbase-error-not-a-hostport-pair – maxteneff

答えて

1

HBaseサーバーとHBaseクライアントジャーのバージョンが一致していない可能性が最も高いです。

サーバーとクライアントのバージョンを確認する

関連する問題