DEBUG - field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginSuccess with annotation @org.apache.hadoop.metrics2.annotation.Metric(valueName=Time, about=, value=[Rate of successful kerberos logins and latency (milliseconds)], always=false, type=DEFAULT, sampleName=Ops)

DEBUG - field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginFailure with annotation @org.apache.hadoop.metrics2.annotation.Metric(valueName=Time, about=, value=[Rate of failed kerberos logins and latency (milliseconds)], always=false, type=DEFAULT, sampleName=Ops)

DEBUG - UgiMetrics, User and group related metrics

DEBUG - Kerberos krb5 configuration not found, setting default realm to empty

DEBUG -  Creating new Groups object

DEBUG - Trying to load the custom-built native-hadoop library...

DEBUG - Failed to load native-hadoop with error: java.lang.UnsatisfiedLinkError: no hadoop in java.library.path

DEBUG - java.library.path=D:\Program Files\Java\jre7\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;C:\Program Files (x86)\NVIDIA Corporation\PhysX\Common;C:\Program Files (x86)\Intel\iCLS Client\;C:\Program Files\Intel\iCLS Client\;C:\Windows\system32;C:\Windows;C:\Windows\System32\Wbem;C:\Windows\System32\WindowsPowerShell\v1.\;C:\Program Files\Intel\Intel(R) Management Engine Components\DAL;C:\Program Files\Intel\Intel(R) Management Engine Components\IPT;C:\Program Files (x86)\Intel\Intel(R) Management Engine Components\DAL;C:\Program Files (x86)\Intel\Intel(R) Management Engine Components\IPT;C:\Program Files (x86)\Intel\OpenCL SDK\3.0\bin\x86;C:\Program Files (x86)\Intel\OpenCL SDK\3.0\bin\x64;D:\Program Files\Java\jdk1..0_40\bin;D:\Program Files\Java\jdk1..0_40\jre\bin;D:\Program Files\TortoiseSVN\bin;D:\Program Files (x86)\ant\bin;D:\Program Files\maven3\bin;.

 WARN - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable

DEBUG - Falling back to shell based

DEBUG - Group mapping impl=org.apache.hadoop.security.ShellBasedUnixGroupsMapping

DEBUG - Group mapping impl=org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback; cacheTimeout=

DEBUG - hadoop login

DEBUG - hadoop login commit

DEBUG - using local user:NTUserPrincipal: Administrator

DEBUG - UGI loginUser:Administrator (auth:SIMPLE)

DEBUG - dfs.client.use.legacy.blockreader.local = false

DEBUG - dfs.client.read.shortcircuit = false

DEBUG - dfs.client.domain.socket.data.traffic = false

DEBUG - dfs.domain.socket.path =

DEBUG - StartupProgress, NameNode startup progress

DEBUG - multipleLinearRandomRetry = null

DEBUG - rpcKind=RPC_PROTOCOL_BUFFER, rpcRequestWrapperClass=class org.apache.hadoop.ipc.ProtobufRpcEngine$RpcRequestWrapper, rpcInvoker=org.apache.hadoop.ipc.ProtobufRpcEngine$Server$ProtoBufRpcInvoker@1afde4a3

DEBUG - Both short-circuit local reads and UNIX domain socket are disabled.

DEBUG - The ping interval is  ms.

DEBUG - Connecting to /192.168.0.160:

DEBUG - IPC Client () connection to /192.168.0.160: from Administrator: starting, having connections

DEBUG - IPC Client () connection to /192.168.0.160: from Administrator sending #

DEBUG - IPC Client () connection to /192.168.0.160: from Administrator got value #

DEBUG - Call: getListing took 136ms

ls: /

==========================================================

name: hdfs://192.168.0.160:8020/data, folder: true, size: 0

name: hdfs://192.168.0.160:8020/fulong, folder: true, size: 0

name: hdfs://192.168.0.160:8020/test, folder: true, size: 0

name: hdfs://192.168.0.160:8020/tmp, folder: true, size: 0

name: hdfs://192.168.0.160:8020/user, folder: true, size: 0

name: hdfs://192.168.0.160:8020/workspace, folder: true, size: 0

==========================================================

DEBUG - Stopping client

DEBUG - IPC Client () connection to /192.168.0.160: from Administrator: closed

DEBUG - IPC Client () connection to /192.168.0.160: from Administrator: stopped, remaining connections 

package com.rockontrol.tryhbase;

import static org.junit.Assert.*;

import java.io.IOException;

import java.io.InputStream;

import java.util.Random;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.HColumnDescriptor;

import org.apache.hadoop.hbase.HTableDescriptor;

import org.apache.hadoop.hbase.KeyValue;

import org.apache.hadoop.hbase.client.Get;

import org.apache.hadoop.hbase.client.HBaseAdmin;

import org.apache.hadoop.hbase.client.HTable;

import org.apache.hadoop.hbase.client.HTablePool;

import org.apache.hadoop.hbase.client.Put;

import org.apache.hadoop.hbase.client.Result;

import org.apache.hadoop.hbase.client.ResultScanner;

import org.apache.hadoop.hbase.client.Scan;

import org.apache.hadoop.hbase.filter.PrefixFilter;

import org.apache.hadoop.hbase.util.Bytes;

import org.apache.log4j.Logger;

import org.junit.Test;

public class TestUseHbase {

   private String table = "Tenant";

   private String cfs[] = {"i"};

   private final int availableProcessors =

         Runtime.getRuntime().availableProcessors();

   private ExecutorService exec =

         Executors.newFixedThreadPool(availableProcessors*);

   private Random rnd = new Random();

   private final int ROW_KEY_LEN = Bytes.SIZEOF_LONG + Bytes.SIZEOF_BYTE;

   private final String colId = "id";

   private final String colStat = "stat";

   private final String colCert = "cert";

   private Configuration conf;

   private HTablePool pool;

   private static final Logger logger =

         Logger.getLogger(TestUseHbase.class);

   public TestUseHbase() throws Exception {

      conf = new Configuration();

      conf.addResource(getHbaseConfStream());

      pool = new HTablePool(conf, );

   }

   @Test

   public void testSetupTable() throws Exception {

      HBaseAdmin admin = new HBaseAdmin(conf);

      try {

         if (admin.tableExists(table)) {

            logger.info("table already exists!");

         } else {

            HTableDescriptor tableDesc =new HTableDescriptor(table);

            for(String cf : cfs) {

               tableDesc.addFamily(new HColumnDescriptor(cf));

            }

            admin.createTable(tableDesc);

            logger.info("table created!");

         }

      } finally {

         admin.close();

      }

   }

   @Test

   public void testPuts() throws Exception {

      final HTable htable = (HTable) pool.getTable(table);

      // put random id

      for (int i = ; i < ; i++) {

         exec.execute(new Runnable() {

            @Override

            public void run() {

               long authId = getAuthId();

               byte[] rowkey = createRowKey(authId, (byte) );

               htable.setAutoFlush(false);

               Put put = new Put(rowkey);

               put.add(cfs[].getBytes(), colId.getBytes(), String.valueOf(authId)

                     .getBytes());

               put.add(cfs[].getBytes(), colStat.getBytes(), String.valueOf()

                     .getBytes());

               try {

                  synchronized (htable) {

                     htable.put(put);

                     htable.flushCommits();

                  }

               } catch (IOException e) {

                  logger.error("ERROR: insert authId=" + authId, e);

               }

            }

         });

      }

      exec.shutdown();

      int count = ;

      while (!exec.awaitTermination(, TimeUnit.SECONDS)) {

         logger.warn("thread pool is still running");

         if (count++ > ) {

            logger.warn("force to exit anyway...");

            break;

         }

      }

      htable.flushCommits();

      pool.putTable(htable);

   }

   @Test

   public void testFullScan() throws Exception {

      HTable htable = (HTable) pool.getTable(table);

      long last = Long.MIN_VALUE;

      ResultScanner rs = htable.getScanner(new Scan());

      long authId = ;

      byte stat = ;

      String strAuthId;

      String strStat;

      for (Result r : rs) {

         KeyValue kvId = r.getColumnLatest(cfs[].getBytes(), colId.getBytes());

         KeyValue kvStat = r.getColumnLatest(cfs[].getBytes(), colStat.getBytes());

         if (kvId != null && kvStat != null) {

            strAuthId = new String(kvId.getValue());

            strStat = new String(kvStat.getValue());

            authId = getIdByRowKey(kvId.getKey());

            stat = getStatByRowKey(kvId.getKey());

            assertTrue("last=" + last +

                  ", current=" + authId, authId >= last); // incremental sorted

            last = authId;

            logger.info("authId=" + authId + ", stat=" + stat + ", value=[" + strAuthId

                  + ", " + strStat + "]");

         } else {

            for (KeyValue kv : r.raw()) {

               authId = getIdByRowKey(kv.getKey());

               stat = getStatByRowKey(kv.getKey());

               assertTrue("last=" + last +

                     ", current=" + authId, authId >= last); // incremental sort

               last = authId;

               logger.info("authId=" + authId + ", stat=" + stat);

               logger.info(new String(kv.getValue()));

            }

         }

      }

   }

   @Test

   public void testSpecScan() throws Exception {

      HTable htable = (HTable) pool.getTable(table);

      long specId = getAuthId();

      byte[] rowkey = createRowKey(specId, (byte) );

      // PUT

      Put put = new Put(rowkey);

      put.add(cfs[].getBytes(), colId.getBytes(), String.valueOf(specId)

            .getBytes());

      put.add(cfs[].getBytes(), colStat.getBytes(), String.valueOf()

            .getBytes());

      htable.put(put);

      // Get with rowkey

      Get scan = new Get(rowkey);

      Result r = htable.get(scan);

      assertTrue(!r.isEmpty());

      long id = ;

      for(KeyValue kv : r.raw()) {

         id = getIdByRowKey(kv.getKey());

         assertEquals(specId, id);

         logger.info("authId=" + id +

               ", cf=" + new String(kv.getFamily()) +

               ", key=" + new String(kv.getQualifier()) +

               ", value=" + new String(kv.getValue()));

      }

      // Put with specId but stat and different column

      rowkey = createRowKey(specId, (byte));

      put = new Put(rowkey);

      put.add(cfs[].getBytes(), colCert.getBytes(), "xyz".getBytes());

      htable.put(put);

      // Get with rowkey prefix

      Scan s = new Scan();

      s.setFilter(new PrefixFilter(createRowKeyPrefix(specId)));

      ResultScanner rs = htable.getScanner(s);

      for(Result ret : rs) {

         String strk = new String(ret.getRow());

         logger.info("ret=" + strk);

         for(KeyValue kv : ret.raw()) {

            id = getIdByRowKey(kv.getKey());

            assertEquals(specId, id);

            logger.info("authId=" + id +

                  ", stat=" + getStatByRowKey(kv.getKey()) +

                  ", cf=" + new String(kv.getFamily()) +

                  ", key=" + new String(kv.getQualifier()) +

                  ", value=" + new String(kv.getValue()));

         }

      }

      // Get with start and end row

      s = new Scan();

      s.setStartRow(createRowKeyPrefix(specId));

      s.setStopRow(createRowKeyPrefix(specId+));

      rs = htable.getScanner(s);

      for(Result ret : rs) {

         String strk = new String(ret.getRow());

         logger.info("ret=" + strk);

         for(KeyValue kv : ret.raw()) {

            id = getIdByRowKey(kv.getKey());

            assertEquals(specId, id);

            logger.info("authId=" + id +

                  ", stat=" + getStatByRowKey(kv.getKey()) +

                  ", cf=" + new String(kv.getFamily()) +

                  ", key=" + new String(kv.getQualifier()) +

                  ", value=" + new String(kv.getValue()));

         }

      }

   }

   @Test

   public void testBytesConv() throws Exception {

      long a = ;

      byte s = ;

      byte[] data = new byte[];

      int off = Bytes.putLong(data, , a);

      Bytes.putByte(data, off, s);

      long b = Bytes.toLong(data);

      byte t = data[];

      assertEquals(a, b);

      assertEquals(s, t);

   }

   private byte[] createRowKey(long authId, byte stat) {

      byte[] rowkey = new byte[ROW_KEY_LEN];

      int off = Bytes.putLong(rowkey, , authId);

      Bytes.putByte(rowkey, off, stat);

      return rowkey;

   }

   private byte[] createRowKeyPrefix(long authId) {

      byte[] prefix = new byte[Bytes.SIZEOF_LONG];

      Bytes.putLong(prefix, , authId);

      return prefix;

   }

   private long getIdByRowKey(byte[] rowkey) {

      // HACK

      return Bytes.toLong(rowkey, Bytes.SIZEOF_SHORT);

   }

   private byte getStatByRowKey(byte[] rowkey) {

      // HACK

      return rowkey[Bytes.SIZEOF_SHORT + ROW_KEY_LEN - ];

   }

   private long getAuthId() {

      long authId = rnd.nextLong();

      authId = authId >  ? authId : -authId;

      return authId;

   }

   private static InputStream getHbaseConfStream() throws Exception {

      return TestUseHbase.class.getClassLoader().getResourceAsStream("hbase-site.xml");

   }

}

-- ::  [ main: ] - [ DEBUG ]  field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginSuccess with annotation @org.apache.hadoop.metrics2.annotation.Metric(valueName=Time, about=, value=[Rate of successful kerberos logins and latency (milliseconds)], always=false, type=DEFAULT, sampleName=Ops)

-- ::  [ main: ] - [ DEBUG ]  field org.apache.hadoop.metrics2.lib.MutableRate org.apache.hadoop.security.UserGroupInformation$UgiMetrics.loginFailure with annotation @org.apache.hadoop.metrics2.annotation.Metric(valueName=Time, about=, value=[Rate of failed kerberos logins and latency (milliseconds)], always=false, type=DEFAULT, sampleName=Ops)

-- ::  [ main: ] - [ DEBUG ]  UgiMetrics, User and group related metrics

-- ::  [ main: ] - [ DEBUG ]  Kerberos krb5 configuration not found, setting default realm to empty

-- ::  [ main: ] - [ DEBUG ]   Creating new Groups object

-- ::  [ main: ] - [ DEBUG ]  Trying to load the custom-built native-hadoop library...

-- ::  [ main: ] - [ DEBUG ]  Failed to load native-hadoop with error: java.lang.UnsatisfiedLinkError: no hadoop in java.library.path

-- ::  [ main: ] - [ DEBUG ]  java.library.path=D:\Program Files\Java\jdk1..0_45\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;D:\Perl64\bin;D:\Perl64\site\bin;C:\Program Files (x86)\Common Files\NetSarang;C:\Program Files (x86)\Intel\iCLS Client\;C:\Program Files\Intel\iCLS Client\;C:\Windows\system32;C:\Windows;C:\Windows\System32\Wbem;C:\Windows\System32\WindowsPowerShell\v1.\;C:\Program Files (x86)\Intel\OpenCL SDK\2.0\bin\x86;C:\Program Files (x86)\Intel\OpenCL SDK\2.0\bin\x64;C:\Program Files\Intel\Intel(R) Management Engine Components\DAL;C:\Program Files\Intel\Intel(R) Management Engine Components\IPT;C:\Program Files (x86)\Intel\Intel(R) Management Engine Components\DAL;C:\Program Files (x86)\Intel\Intel(R) Management Engine Components\IPT;D:\java\maven/bin;D:\Program Files\Java\jdk1.8.0/bin;d:\Program Files (x86)\YYXT\AudioEditorOCX;D:\Program Files\MySQL\MySQL Server 5.5\bin;D:\hadoop\apache-ant-1.9.\bin;D:\Program Files\nodejs\;D:\Program Files\TortoiseSVN\bin;D:\Perl64\bin;D:\Perl64\site\bin;C:\Users\lenovo\AppData\Roaming\npm;.

-- ::  [ main: ] - [ WARN ]  Unable to load native-hadoop library for your platform... using builtin-java classes where applicable

-- ::  [ main: ] - [ DEBUG ]  Falling back to shell based

-- ::  [ main: ] - [ DEBUG ]  Group mapping impl=org.apache.hadoop.security.ShellBasedUnixGroupsMapping

-- ::  [ main: ] - [ DEBUG ]  Group mapping impl=org.apache.hadoop.security.JniBasedUnixGroupsMappingWithFallback; cacheTimeout=

-- ::  [ main: ] - [ DEBUG ]  hadoop login

-- ::  [ main: ] - [ DEBUG ]  hadoop login commit

-- ::  [ main: ] - [ DEBUG ]  using local user:NTUserPrincipal: lenovo

-- ::  [ main: ] - [ DEBUG ]  UGI loginUser:lenovo (auth:SIMPLE)

-- ::  [ main: ] - [ INFO ]  Client environment:zookeeper.version=3.4.-, built on // : GMT

-- ::  [ main: ] - [ INFO ]  Client environment:host.name=qiaokai-PC

-- ::  [ main: ] - [ INFO ]  Client environment:java.version=1.7.0_45

-- ::  [ main: ] - [ INFO ]  Client environment:java.vendor=Oracle Corporation

-- ::  [ main: ] - [ INFO ]  Client environment:java.home=D:\Program Files\Java\jdk1..0_45\jre

-- ::  [ main: ] - [ INFO ]  Client environment:java.class.path=D:\Users\lenovo\koalaSP\dbhbase\target\classes;D:\java\mavenRepo\org\apache\hbase\hbase-client\0.96.-hadoop2\hbase-client-0.96.-hadoop2.jar;D:\java\mavenRepo\org\apache\hbase\hbase-common\0.96.-hadoop2\hbase-common-0.96.-hadoop2.jar;D:\java\mavenRepo\commons-collections\commons-collections\3.2.\commons-collections-3.2..jar;D:\java\mavenRepo\org\apache\hbase\hbase-protocol\0.96.-hadoop2\hbase-protocol-0.96.-hadoop2.jar;D:\java\mavenRepo\commons-codec\commons-codec\1.7\commons-codec-1.7.jar;D:\java\mavenRepo\commons-io\commons-io\2.4\commons-io-2.4.jar;D:\java\mavenRepo\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;D:\java\mavenRepo\commons-logging\commons-logging\1.1.\commons-logging-1.1..jar;D:\java\mavenRepo\com\google\guava\guava\12.0.\guava-12.0..jar;D:\java\mavenRepo\com\google\code\findbugs\jsr305\1.3.\jsr305-1.3..jar;D:\java\mavenRepo\com\google\protobuf\protobuf-java\2.5.\protobuf-java-2.5..jar;D:\java\mavenRepo\io\netty\netty\3.6..Final\netty-3.6..Final.jar;D:\java\mavenRepo\org\apache\zookeeper\zookeeper\3.4.\zookeeper-3.4..jar;D:\java\mavenRepo\org\slf4j\slf4j-api\1.6.\slf4j-api-1.6..jar;D:\java\mavenRepo\org\slf4j\slf4j-log4j12\1.6.\slf4j-log4j12-1.6..jar;D:\java\mavenRepo\org\cloudera\htrace\htrace-core\2.04\htrace-core-2.04.jar;D:\java\mavenRepo\org\codehaus\jackson\jackson-mapper-asl\1.8.\jackson-mapper-asl-1.8..jar;D:\java\mavenRepo\org\apache\hadoop\hadoop-common\2.2.\hadoop-common-2.2..jar;D:\java\mavenRepo\org\apache\commons\commons-math\2.1\commons-math-2.1.jar;D:\java\mavenRepo\commons-httpclient\commons-httpclient\3.1\commons-httpclient-3.1.jar;D:\java\mavenRepo\commons-net\commons-net\3.1\commons-net-3.1.jar;D:\java\mavenRepo\com\sun\jersey\jersey-json\1.9\jersey-json-1.9.jar;D:\java\mavenRepo\org\codehaus\jettison\jettison\1.1\jettison-1.1.jar;D:\java\mavenRepo\stax\stax-api\1.0.\stax-api-1.0..jar;D:\java\mavenRepo\com\sun\xml\bind\jaxb-impl\2.2.-\jaxb-impl-2.2.-.jar;D:\java\mavenRepo\javax\xml\bind\jaxb-api\2.2.\jaxb-api-2.2..jar;D:\java\mavenRepo\javax\activation\activation\1.1\activation-1.1.jar;D:\java\mavenRepo\org\codehaus\jackson\jackson-jaxrs\1.8.\jackson-jaxrs-1.8..jar;D:\java\mavenRepo\org\codehaus\jackson\jackson-xc\1.8.\jackson-xc-1.8..jar;D:\java\mavenRepo\commons-el\commons-el\1.0\commons-el-1.0.jar;D:\java\mavenRepo\net\java\dev\jets3t\jets3t\0.6.\jets3t-0.6..jar;D:\java\mavenRepo\commons-configuration\commons-configuration\1.6\commons-configuration-1.6.jar;D:\java\mavenRepo\commons-digester\commons-digester\1.8\commons-digester-1.8.jar;D:\java\mavenRepo\commons-beanutils\commons-beanutils\1.7.\commons-beanutils-1.7..jar;D:\java\mavenRepo\commons-beanutils\commons-beanutils-core\1.8.\commons-beanutils-core-1.8..jar;D:\java\mavenRepo\org\apache\avro\avro\1.7.\avro-1.7..jar;D:\java\mavenRepo\com\thoughtworks\paranamer\paranamer\2.3\paranamer-2.3.jar;D:\java\mavenRepo\org\xerial\snappy\snappy-java\1.0.4.1\snappy-java-1.0.4.1.jar;D:\java\mavenRepo\com\jcraft\jsch\0.1.\jsch-0.1..jar;D:\java\mavenRepo\org\apache\commons\commons-compress\1.4.\commons-compress-1.4..jar;D:\java\mavenRepo\org\tukaani\xz\1.0\xz-1.0.jar;D:\java\mavenRepo\org\apache\hadoop\hadoop-auth\2.2.\hadoop-auth-2.2..jar;D:\java\mavenRepo\org\apache\hadoop\hadoop-mapreduce-client-core\2.2.\hadoop-mapreduce-client-core-2.2..jar;D:\java\mavenRepo\org\apache\hadoop\hadoop-yarn-common\2.2.\hadoop-yarn-common-2.2..jar;D:\java\mavenRepo\org\apache\hadoop\hadoop-yarn-api\2.2.\hadoop-yarn-api-2.2..jar;D:\java\mavenRepo\com\google\inject\guice\3.0\guice-3.0.jar;D:\java\mavenRepo\javax\inject\javax.inject\\javax.inject-.jar;D:\java\mavenRepo\aopalliance\aopalliance\1.0\aopalliance-1.0.jar;D:\java\mavenRepo\com\sun\jersey\contribs\jersey-guice\1.9\jersey-guice-1.9.jar;D:\java\mavenRepo\com\google\inject\extensions\guice-servlet\3.0\guice-servlet-3.0.jar;D:\java\mavenRepo\org\apache\hadoop\hadoop-annotations\2.2.\hadoop-annotations-2.2..jar;D:\java\mavenRepo\com\github\stephenc\findbugs\findbugs-annotations\1.3.-\findbugs-annotations-1.3.-.jar;D:\java\mavenRepo\junit\junit\4.11\junit-4.11.jar;D:\java\mavenRepo\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar;D:\java\mavenRepo\org\apache\hadoop\hadoop-hdfs\2.2.\hadoop-hdfs-2.2..jar;D:\java\mavenRepo\org\mortbay\jetty\jetty\6.1.\jetty-6.1..jar;D:\java\mavenRepo\org\mortbay\jetty\jetty-util\6.1.\jetty-util-6.1..jar;D:\java\mavenRepo\com\sun\jersey\jersey-core\1.9\jersey-core-1.9.jar;D:\java\mavenRepo\com\sun\jersey\jersey-server\1.9\jersey-server-1.9.jar;D:\java\mavenRepo\asm\asm\3.1\asm-3.1.jar;D:\java\mavenRepo\commons-cli\commons-cli\1.2\commons-cli-1.2.jar;D:\java\mavenRepo\commons-daemon\commons-daemon\1.0.\commons-daemon-1.0..jar;D:\java\mavenRepo\javax\servlet\jsp\jsp-api\2.1\jsp-api-2.1.jar;D:\java\mavenRepo\log4j\log4j\1.2.\log4j-1.2..jar;D:\java\mavenRepo\javax\servlet\servlet-api\2.5\servlet-api-2.5.jar;D:\java\mavenRepo\org\codehaus\jackson\jackson-core-asl\1.8.\jackson-core-asl-1.8..jar;D:\java\mavenRepo\tomcat\jasper-runtime\5.5.\jasper-runtime-5.5..jar;D:\java\mavenRepo\xmlenc\xmlenc\0.52\xmlenc-0.52.jar;D:\Program Files\Java\jdk1.8.0\lib\tools.jar

-- ::  [ main: ] - [ INFO ]  Client environment:java.library.path=D:\Program Files\Java\jdk1..0_45\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;D:\Perl64\bin;D:\Perl64\site\bin;C:\Program Files (x86)\Common Files\NetSarang;C:\Program Files (x86)\Intel\iCLS Client\;C:\Program Files\Intel\iCLS Client\;C:\Windows\system32;C:\Windows;C:\Windows\System32\Wbem;C:\Windows\System32\WindowsPowerShell\v1.\;C:\Program Files (x86)\Intel\OpenCL SDK\2.0\bin\x86;C:\Program Files (x86)\Intel\OpenCL SDK\2.0\bin\x64;C:\Program Files\Intel\Intel(R) Management Engine Components\DAL;C:\Program Files\Intel\Intel(R) Management Engine Components\IPT;C:\Program Files (x86)\Intel\Intel(R) Management Engine Components\DAL;C:\Program Files (x86)\Intel\Intel(R) Management Engine Components\IPT;D:\java\maven/bin;D:\Program Files\Java\jdk1.8.0/bin;d:\Program Files (x86)\YYXT\AudioEditorOCX;D:\Program Files\MySQL\MySQL Server 5.5\bin;D:\hadoop\apache-ant-1.9.\bin;D:\Program Files\nodejs\;D:\Program Files\TortoiseSVN\bin;D:\Perl64\bin;D:\Perl64\site\bin;C:\Users\lenovo\AppData\Roaming\npm;.

-- ::  [ main: ] - [ INFO ]  Client environment:java.io.tmpdir=C:\Users\lenovo\AppData\Local\Temp\

-- ::  [ main: ] - [ INFO ]  Client environment:java.compiler=<NA>

-- ::  [ main: ] - [ INFO ]  Client environment:os.name=Windows

-- ::  [ main: ] - [ INFO ]  Client environment:os.arch=amd64

-- ::  [ main: ] - [ INFO ]  Client environment:os.version=6.1

-- ::  [ main: ] - [ INFO ]  Client environment:user.name=lenovo

-- ::  [ main: ] - [ INFO ]  Client environment:user.home=C:\Users\lenovo

-- ::  [ main: ] - [ INFO ]  Client environment:user.dir=D:\Users\lenovo\koalaSP\dbhbase

-- ::  [ main: ] - [ INFO ]  Initiating client connection, connectString=compute1: sessionTimeout= watcher=hconnection-0xda5a705, quorum=compute1:, baseZNode=/hbase

-- ::  [ main: ] - [ DEBUG ]  zookeeper.disableAutoWatchReset is false

-- ::  [ main: ] - [ INFO ]  Process identifier=hconnection-0xda5a705 connecting to ZooKeeper ensemble=compute1:

-- ::  [ main-SendThread(compute1:): ] - [ INFO ]  Opening socket connection to server compute1/192.168.11.39:. Will not attempt to authenticate using SASL (unknown error)

-- ::  [ main-SendThread(compute1:): ] - [ INFO ]  Socket connection established to compute1/192.168.11.39:, initiating session

-- ::  [ main-SendThread(compute1:): ] - [ DEBUG ]  Session establishment request sent on compute1/192.168.11.39:

-- ::  [ main-SendThread(compute1:): ] - [ INFO ]  Session establishment complete on server compute1/192.168.11.39:, sessionid = 0x2483a55a18c0013, negotiated timeout =

-- ::  [ main-EventThread: ] - [ DEBUG ]  hconnection-0xda5a705, quorum=compute1:, baseZNode=/hbase Received ZooKeeper Event, type=None, state=SyncConnected, path=null

-- ::  [ main-EventThread: ] - [ DEBUG ]  hconnection-0xda5a705-0x2483a55a18c0013 connected

-- ::  [ main-SendThread(compute1:): ] - [ DEBUG ]  Reading reply sessionid:0x2483a55a18c0013, packet:: clientPath:null serverPath:null finished:false header:: ,  replyHeader:: ,,  request:: '/hbase/hbaseid,F  response:: s{4294967310,4294967310,1409728069737,1409728069737,0,0,0,0,67,0,4294967310}

-- ::  [ main-SendThread(compute1:): ] - [ DEBUG ]  Reading reply sessionid:0x2483a55a18c0013, packet:: clientPath:null serverPath:null finished:false header:: ,  replyHeader:: ,,  request:: '/hbase/hbaseid,F  response:: #ffffffff000146d61737465723a363030303033ffffff8036ffffff94ffffffabcfffffffd6750425546a2430643537303664662d653431622d343332382d383833342d356533643531363362393736,s{4294967310,4294967310,1409728069737,1409728069737,0,0,0,0,67,0,4294967310}

-- ::  [ main: ] - [ DEBUG ]  Codec=org.apache.hadoop.hbase.codec.KeyValueCodec@453d9468, compressor=null, tcpKeepAlive=true, tcpNoDelay=true, maxIdleTime=, maxRetries=, fallbackAllowed=false, ping interval=60000ms, bind address=null

-- ::  [ main-SendThread(compute1:): ] - [ DEBUG ]  Reading reply sessionid:0x2483a55a18c0013, packet:: clientPath:null serverPath:null finished:false header:: ,  replyHeader:: ,,  request:: '/hbase/meta-region-server,F  response:: #ffffffff0001a726567696f6e7365727665723a3630303230ffffffff133cffffff88341c1effffffef50425546a15a8636f6d707574653110fffffff4ffffffd4318ffffffe4ffffffefffffffdcffffffd2ffffff8329100,s{4294967339,4294967339,1409728076023,1409728076023,0,0,0,0,60,0,4294967339}

-- ::  [ main-SendThread(compute1:): ] - [ DEBUG ]  Reading reply sessionid:0x2483a55a18c0013, packet:: clientPath:null serverPath:null finished:false header:: ,  replyHeader:: ,,  request:: '/hbase/meta-region-server,F  response:: #ffffffff0001a726567696f6e7365727665723a3630303230ffffffff133cffffff88341c1effffffef50425546a15a8636f6d707574653110fffffff4ffffffd4318ffffffe4ffffffefffffffdcffffffd2ffffff8329100,s{4294967339,4294967339,1409728076023,1409728076023,0,0,0,0,60,0,4294967339}

-- ::  [ main-SendThread(compute1:): ] - [ DEBUG ]  Reading reply sessionid:0x2483a55a18c0013, packet:: clientPath:null serverPath:null finished:false header:: ,  replyHeader:: ,,  request:: '/hbase/meta-region-server,F  response:: #ffffffff0001a726567696f6e7365727665723a3630303230ffffffff133cffffff88341c1effffffef50425546a15a8636f6d707574653110fffffff4ffffffd4318ffffffe4ffffffefffffffdcffffffd2ffffff8329100,s{4294967339,4294967339,1409728076023,1409728076023,0,0,0,0,60,0,4294967339}

-- ::  [ main: ] - [ DEBUG ]  Use SIMPLE authentication for service ClientService, sasl=false

-- ::  [ main: ] - [ DEBUG ]  Connecting to compute1/192.168.11.39:

-- ::  [ IPC Client () connection to compute1/192.168.11.39: from lenovo: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: starting, connections

-- ::  [ main: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: wrote request header call_id:  method_name: "Get" request_param: true

-- ::  [ IPC Client () connection to compute1/192.168.11.39: from lenovo: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: got response header call_id: , totalSize:  bytes

-- ::  [ main-SendThread(compute1:): ] - [ DEBUG ]  Reading reply sessionid:0x2483a55a18c0013, packet:: clientPath:null serverPath:null finished:false header:: ,  replyHeader:: ,,  request:: '/hbase/meta-region-server,F  response:: #ffffffff0001a726567696f6e7365727665723a3630303230ffffffff133cffffff88341c1effffffef50425546a15a8636f6d707574653110fffffff4ffffffd4318ffffffe4ffffffefffffffdcffffffd2ffffff8329100,s{4294967339,4294967339,1409728076023,1409728076023,0,0,0,0,60,0,4294967339}

-- ::  [ main: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: wrote request header call_id:  method_name: "Scan" request_param: true

-- ::  [ IPC Client () connection to compute1/192.168.11.39: from lenovo: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: got response header call_id: , totalSize:  bytes

-- ::  [ main: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: wrote request header call_id:  method_name: "Scan" request_param: true priority:

-- ::  [ IPC Client () connection to compute1/192.168.11.39: from lenovo: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: got response header call_id:  cell_block_meta { length:  }, totalSize:  bytes

-- ::  [ main: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: wrote request header call_id:  method_name: "Scan" request_param: true

-- ::  [ IPC Client () connection to compute1/192.168.11.39: from lenovo: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: got response header call_id: , totalSize:  bytes

-- ::  [ main: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: wrote request header call_id:  method_name: "Scan" request_param: true

-- ::  [ IPC Client () connection to compute1/192.168.11.39: from lenovo: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: got response header call_id: , totalSize:  bytes

-- ::  [ main: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: wrote request header call_id:  method_name: "Scan" request_param: true

-- ::  [ IPC Client () connection to compute1/192.168.11.39: from lenovo: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: got response header call_id: , totalSize:  bytes

-- ::  [ main: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: wrote request header call_id:  method_name: "Scan" request_param: true

-- ::  [ IPC Client () connection to compute1/192.168.11.39: from lenovo: ] - [ DEBUG ]  IPC Client () connection to compute1/192.168.11.39: from lenovo: got response header call_id: , totalSize:  bytes