無法在遠程hbase表中插入記錄

Question

我正試圖在htable中插入一條記錄。該程序沒有結束，但它打印後掛起111.請幫助。

public static void insert(){ 
    org.apache.hadoop.conf.Configuration config = HBaseConfiguration.create(); 
    HTable table = null; 
    try{ 
    config.set("hbase.zookeeper.quorum","ip_address_of_remotemachine"); 
    config.set("hbase.zookeeper.property.clientPort","2181"); 
    config.set("hbase.master", "hdfs://remote_ip:2181/hbase"); 
    table = new HTable(config, "table_A"); 
    Put p = new Put(Bytes.toBytes("1")); 
    p.add(Bytes.toBytes("Col"), Bytes.toBytes("ColFamily1"), Bytes.toBytes("Test123")); 
    System.out.println("111"); 
    table.put(p); 
    System.out.println("222"); 
    table.setAutoFlush(true); 
    } 
    catch(IOException ee){ 
     ee.printStackTrace(); 
    } 
    catch(Exception e){ 
     e.printStackTrace(); 
    } 
    finally{ 
     try { 
      if(table != null) 
      table.close(); 
     } catch (IOException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
     } 
    } 

} 

我得到的輸出作爲

15/07/20 14時28分33秒WARN util.NativeCodeLoader：無法加載 原生的Hadoop庫平臺。 ..使用內建java類 適用15/07/20 14:28:33信息 zookeeper.RecoverableZooKeeper：進程 identifier = hconnection-0x6a79d589連接到ZooKeeper ensemble = 100.101.102.103：2181 15/07/20 14:28:34信息 zookeeper.ZooKeeper：客戶端 環境：zookeeper.version = 3.4.5-mapr-1503--1，建立於03/26/2015 18:33 GMT 15/07/20 14:28:34 INFO zookeeper.ZooKeeper：客戶端 環境：host.name = localhost 15/07/20 14:28:34 INFO zookeeper.ZooKeeper：客戶端環境：java.version = 1.7.0_79 15/07/20 14:28:34 INFO zookeeper.ZooKeeper：客戶端 環境：java.vendor = Oracle Corporation 15/07/20 14:28:34信息 zookeeper.ZooKeeper：客戶端 環境：java.home =/usr/local /java/jdk1.7.0_79/jre 15/07/20 14:28:34 INFO zookeeper.ZooKeeper：Client environment：java.class.path =/usr/local/MyWorks/Flow1/test/target/classes：在/ usr /本地/ testDep /活化法制正1.1.jar：/usr/local/testDep/aopalliance-1.0.jar：/usr/local/testDep/apacheds-i18n-2.0.0-M15.jar：在/ usr /本地/ testDep/ApacheDS中，Kerberos的編解碼器-2.0.0-M15.jar：/usr/local/testDep/api-asn1-api-1.0.0-M20.jar：/usr/local/testDep/api-util-1.0.0-M20.jar：/ USR /本地/ testDep/ASM-3.1.jar：/usr/local/testDep/avro-1.7.4.jar：/usr/local/testDep/commons-beanutils-1.7.0.jar：在/ usr /本地/ testDep /commons-beanutils-core-1.8.0.jar:/usr/local/testDep/commons-cli-1.2.jar:/usr/local/testDep/commons-codec-1.7.jar:/usr/local/testDep/公地集合-3.2.1.jar：/usr/local/testDep/commons-compress-1.4.1.jar：/usr/local/testDep/commons-configuration-1.6.jar：在/ usr /本地/ testDep /公-daemon-1.0.13.jar：/usr/local/testDep/commons-digester-1.8.jar：/usr/local/testDep/commons-el-1.0.jar：在/ usr /本地/ testDep /公地httpclient- 3.1.jar：/usr/local/testDep/commons-io-2.4.jar：/usr/local/testDep/commons-lang-2.6.jar：/usr/local/testDep/commons-logging-1.1.1.jar ：/usr/local/testDep/commons-math3-3.1.1.jar：在/ usr /本地/ testDep /公地MATH- 2.1.jar：/usr/local/testDep/commons-net-3.1.jar：/usr/local/testDep/findbugs-annotations-1.3.9-1.jar：/usr/local/testDep/guava-12.0.1的.jar：/usr/local/testDep/guice-3.0.jar：/usr/local/testDep/guice-servlet-3.0.jar：/usr/local/testDep/hamcrest-core-1.3.jar：在/ usr /本地/testDep/hbase-annotations-0.98.9-mapr-1503.jar:/usr/local/testDep/hbase-checkstyle-0.98.9-mapr-1503.jar:/usr/local/testDep/hbase-client-0.98 0.9-MAPR-1503.jar：/usr/local/testDep/hbase-common-0.98.9-mapr-1503.jar：/usr/local/testDep/hbase-common-0.98.9-mapr-1503-tests的.jar：/usr/local/testDep/hbase-examples-0.98.9-mapr-1503.jar：/usr/local/testDep/hbase-hadoop2-compat-0.98.9-mapr-1503.jar：在/ usr /本地/ testDep/HBase的-Hadoop的COMPAT-0.98.9-MAPR-1503.jar：/usr/local/testDep/hbase-it-0.98.9-mapr-1503.jar：在/ usr /本地/ testDep/hbase-它-0.98.9-MAPR-1503-tests.jar：/usr/local/testDep/hbase-prefix-tree-0.98.9-mapr-1503.jar：/usr/local/testDep/hbase-protocol-0.98。 9- MAPR-1503.jar：/usr/local/testDep/hbase-rest-0.98.9-mapr-1503.jar：在/ usr /本地/ testDep/HBase的-S erver-0.98.9-MAPR-1503.jar：/usr/local/testDep/hbase-server-0.98.9-mapr-1503-tests.jar：/usr/local/testDep/hbase-shell-0.98.9- MAPR-1503.jar：/usr/local/testDep/hbase-testing-util-0.98.9-mapr-1503.jar：/usr/local/testDep/hbase-thrift-0.98.9-mapr-1503.jar： /usr/local/testDep/high-scale-lib-1.1.1.jar:/usr/local/testDep/htrace-core-2.04.jar:/usr/local/testDep/httpclient-4.2.5.jar:/ USR /本地/ testDep /的HttpCore-4.1.3.jar：/usr/local/testDep/jackson-core-asl-1.8.8.jar：/usr/local/testDep/jackson-jaxrs-1.8.8.jar： /usr/local/testDep/jackson-mapper-asl-1.8.8.jar:/usr/local/testDep/jackson-xc-1.8.8.jar:/usr/local/testDep/jamon-runtime-2.3.1的.jar：/usr/local/testDep/jasper-compiler-5.5.23.jar：/usr/local/testDep/jasper-runtime-5.5.23.jar：在/ usr /本地/ testDep /使用javax。注入-1.jar：/usr/local/testDep/java-xmlbuilder-0.4.jar：/usr/local/testDep/jaxb-api-2.2.2.jar：/usr/local/testDep/jaxb-impl-2.2 .3-1.jar：/usr/local/testDep/jcodings-1.0.8.jar：/usr/local/testDep/jersey-client-1.9.jar：/usr/local/testDep/jersey-core-1.8。罐子：/usr/local/testDep/jersey-guice-1.9.jar：/usr/local/testDep/jersey-json-1.8.jar：/usr/local/testDep/jersey-server-1.8.jar：在/ usr /本地/ testDep /的JetS3t-0.9.0.jar：/usr/local/testDep/jettison-1.3.1.jar：/usr/local/testDep/jetty-6.1.26.jar：在/ usr /本地/ testDep /碼頭-sslengine-6.1.26.jar：/usr/local/testDep/jetty-util-6.1.26.jar：/usr/local/testDep/joni-2.1.2.jar：在/ usr /本地/ testDep/jruby-完整-1.6.8.jar：/usr/local/testDep/jsch-0.1.42.jar：/usr/local/testDep/jsp-2.1-6.1.14.jar：在/ usr /本地/ testDep/JSP-API -2.1-6.1.14.jar：/usr/local/testDep/jsr305-1.3.9.jar：/usr/local/testDep/junit-4.11.jar：/usr/local/testDep/leveldbjni-all-1.8。罐子：/usr/local/testDep/libthrift-0.9.0.jar：/usr/local/testDep/log4j-1.2.17.jar：/usr/local/testDep/metrics-core-2.2.0.jar：/ USR/LOC人/ testDep /網狀-3.6.6.Final.jar：/usr/local/testDep/paranamer-2.3.jar：/usr/local/testDep/servlet-api-2.5.jar：在/ usr /本地/ testDep/servlet的-API-2.5-6.1.14.jar：/usr/local/testDep/snappy-java-1.0.4.1.jar：/usr/local/testDep/xmlenc-0.52.jar：在/ usr /本地/ testDep/xz- 1.0.jar：/usr/local/testDep/hadoop-annotations-2.0.5-alpha.jar：/usr/local/testDep/hadoop-annotations-2.4.1-mapr-1408.jar：在/ usr /本地/ testDep /hadoop-auth-2.4.1-mapr-1408.jar:/usr/local/testDep/hadoop-client-2.4.1-mapr-1408.jar:/usr/local/testDep/hadoop-common-2.4.1 -mapr-1408.jar：/usr/local/testDep/hadoop-common-2.4.1-mapr-1408-tests.jar：/usr/local/testDep/hadoop-core-2.4.1-mapr-1408.jar ：/usr/local/testDep/hadoop-hdfs-2.4.1-mapr-1408.jar：/usr/local/testDep/hadoop-hdfs-2.4.1-mapr-1408-tests.jar：在/ usr /本地/ testDep/Hadoop的MapReduce的客戶端應用程序-2.4.1-MAPR-1408.jar：/usr/local/testDep/hadoop-mapreduce-client-common-2.4.1-mapr-1408.jar：在/ usr /本地/ testDep/Hadoop的MapReduce的客戶核心2.4.1-MAPR-1408.jar：在/ usr /本地/ testDep/Hadoop的MapReduce的客戶-HS -2.4.1-MAPR-1408.jar：/usr/local/testDep/hadoop-mapreduce-client-jobclient-2.4.1-mapr-1408.jar：在/ usr /本地/ testDep/Hadoop的MapReduce的客戶jobclient -2.4.1-MAPR-1408-tests.jar：/usr/local/testDep/hadoop-mapreduce-client-shuffle-2.4.1-mapr-1408.jar：/usr/local/testDep/hadoop-minicluster-2.4 .1 MAPR-1408.jar：/usr/local/testDep/hadoop-test-2.4.1-mapr-1408.jar：/usr/local/testDep/hadoop-yarn-api-2.4.1-mapr-1408的.jar：/usr/local/testDep/hadoop-yarn-client-2.4.1-mapr-1408.jar：/usr/local/testDep/hadoop-yarn-common-2.4.1-mapr-1408.jar：/ USR /本地/ testDep/Hadoop的紗服務器applicationhistoryservice-2.4.1-MAPR-1408.jar：/usr/local/testDep/hadoop-yarn-server-common-2.4.1-mapr-1408.jar：/ USR /本地/ testDep/Hadoop的紗服務器節點管理器-2.4.1-MAPR-1408.jar：/usr/local/testDep/hadoop-yarn-server-resourcemanager-2.4.1-mapr-1408.jar：/ USR /本地/ testDep/Hadoop的紗服務器測試-2.4.1-MAPR-1408-tests.jar：/usr/local/testDep/hadoop-yarn-server-web-proxy-2.4.1-mapr-1408的.jar：/usr/local/testDep/zookeeper-3.4.5-mapr-1503。罐子：/usr/local/testDep/hbase-utils-4.1.0-mapr.jar：/usr/local/testDep/hibernate-c3p0-3.3.1.GA.jar：在/ usr /本地/ testDep /休眠公地-annotations-3.2.0.Final.jar：/usr/local/testDep/hibernate-core-3.6.8.Final.jar：/usr/local/testDep/httpclient-4.2.jar：在/ usr /本地/ testDep/HttpClient的緩存-4.2.jar：/usr/local/testDep/httpcore-4.2.jar：/usr/local/testDep/jasper-compiler-5.5.12.jar：/usr/local/testDep/jasper-runtime-5.5 .12.jar：/usr/local/testDep/javassist-3.12.1.GA.jar：/usr/local/testDep/jetty-plus-6.1.26.jar：/usr/local/testDep/jobmngmnt-4.1。 0-mapr.jar：/usr/local/testDep/joda-time-2.0.jar：/usr/local/testDep/JPam-1.1.jar：/usr/local/testDep/json-20080701.jar：在/ usr /本地/ testDep/JSP-2.1.jar：/usr/local/testDep/jsp-api-2.1.jar：/usr/local/testDep/jta-1.1.jar：/usr/local/testDep/junit-3.8.1的.jar：/usr/local/testDep/junit-4.5.jar：/usr/local/testDep/kvstore-4.1.0-mapr.jar：/usr/local/testDep/libprotodefs-4.1.0-mapr.jar： /usr/local/testDep/log4j-1.2.15.jar:/usr/local/testDep/mail.jar:/usr/local/testDep/maprbuil dversion-4.1.0-mapr.jar：/usr/local/testDep/maprcli-4.1.0-mapr.jar：/usr/local/testDep/maprfs-4.1.0-mapr.jar：在/ usr /本地/ testDep /maprfs-core-4.1.0-mapr.jar:/usr/local/testDep/maprfs-core-4.1.0-mapr-tests.jar:/usr/local/testDep/maprfs-diagnostic-tools-4.1.0 -mapr.jar：/usr/local/testDep/maprfs-jni-4.1.0-mapr.jar：/usr/local/testDep/mapr-hbase-4.1.0-mapr.jar：在/ usr /本地/ testDep/MAPR-HBase的-4.1.0-MAPR-tests.jar：/usr/local/testDep/maprutil-4.1.0-mapr.jar：/usr/local/testDep/maven-ant-tasks-2.1.3.jar： /usr/local/testDep/mysql-connector-java-5.1.25-bin.jar:/usr/local/testDep/persistence-api-1.0.jar:/usr/local/testDep/protobuf-java-2.5.0的.jar：/usr/local/testDep/servlet-api-2.5-6.1.26.jar：/usr/local/testDep/slf4j-api-1.7.5.jar：在/ usr /本地/ testDep/SLF4J-log4j12- 1.7.5.jar：/usr/local/testDep/snakeyaml-1.14.jar：/usr/local/testDep/volumemirror-4.1.0-mapr.jar：/usr/local/testDep/warden-4.1.0-mapr .jar 15/07/20 14:28:34 INFO zookeeper。ZooKeeper：Client environment：java.library.path =/usr/java/packages/lib/amd64：/ usr/lib64：/ lib64：/ lib：/ usr/lib 15/07/20 14:28:34 INFO zookeeper.ZooKeeper：客戶端 環境：java.io.tmpdir =/tmp 15/07/20 14:28:34信息 zookeeper.ZooKeeper：客戶端環境：java.compiler = 15/07/20 14:28:34 INFO zookeeper.ZooKeeper：客戶端環境：os.name = Linux 15/07/20 14:28:34 INFO zookeeper.ZooKeeper：Client environment：os.arch = amd64 15/07/20 14:28:34 INFO zookeeper .ZooKeeper： 客戶端環境：os.version = 3.13.0-33-generic 15/07/20 14:28:34信息 zookeeper.ZooKeeper：客戶端環境：user.name = user 15/07/20 14： 28:34 INFO zookeeper.ZooKeeper：客戶端 env ironment：user.home =/usr/local 15/07/20 14:28:34信息 zookeeper.ZooKeeper：客戶端 環境：user.dir =/usr/local/MyWorks/Flow1/test 15/07/20 14 ：28：34 INFO zookeeper.ZooKeeper：發起客戶端連接， connectString中= 100.101.102.103：2181 sessionTimeout = 90000 觀察者= hconnection-0x6a79d589，仲裁= 100.101.102.103：2181， baseZNode =/HBase的15/07/20 14:28:39信息zookeeper.Login：成功登錄 。15/07/20 14:28:39信息client.ZooKeeperSaslClient：客戶端 將使用SIMPLE-SECURITY作爲SASL機制。 15/07/20 14:28:39信息 zookeeper.ClientCnxn：打開套接字連接到服務器 100.101.102.103/100.101.102.103:2181。將嘗試使用登錄上下文部分「Client_simple」進行SASL身份驗證15/07/20 14:28:39 INFO zookeeper.ClientCnxn：將套接字連接建立爲 100.101.102.103/100.101.102.103:2181，啓動會話15/07/20 14:28:39 INFO zookeeper.ClientCnxn：會話建立完成 服務器100.101.102.103/100.101.102.103:2181，sessionid = 0x14eab4127f0001a，協商超時= 40000 15/07/20 14:28:39信息 客戶端。 ZooKeeperRegistry：在ZooKeeper的羣ID讀的是空

Answer 1

你需要把你的集羣的HBase-site.xml文件中你的Java應用程序的類路徑。
此外，您需要刪除設置配置對象的代碼。也就是，這些行：

config.set("hbase.zookeeper.quorum","ip_address_of_remotemachine"); 
config.set("hbase.zookeeper.property.clientPort","2181"); 
config.set("hbase.master", "hdfs://remote_ip:2181/hbase");