What did you change (Its hard looking at code to see what line is
different; better to post a diff).
St.Ack
On Thu, Mar 10, 2011 at 6:09 PM, King JKing <beuk...@gmail.com> wrote:
> After change code to
> HTable ht = new HTable(config, "T1");
> byte[] row = Bytes.toBytes(1);
>
> Get get = new Get(row);
> Result result = ht.get(get);
> System.out.println(Bytes.
> toString(result.getValue("F1".getBytes(), "C1".getBytes())));
>
> try {
> Thread.sleep(60000);
> } catch (InterruptedException ex) {
> ex.printStackTrace();
> }
>
> *ht = new HTable(config, "T1");*
> get = new Get(row);
> result = ht.get(get);
>
> System.out.println(Bytes.toString(result.getValue("F1".getBytes(),
> "C1".getBytes())));
>
> I got the error:
>
> 11/03/11 08:57:05 WARN zookeeper.ZKUtil: hconnection-0x12ea29ecc580005
> Unable to get children of node /hbase/rs
> 11/03/11 08:57:05 ERROR zookeeper.ZooKeeperWatcher:
> hconnection-0x12ea29ecc580005 Received unexpected KeeperException,
> re-throwing exception
> org.apache.zookeeper.KeeperException$ConnectionLossException:
> KeeperErrorCode = ConnectionLoss for /hbase/rs
> at
> org.apache.zookeeper.KeeperException.create(KeeperException.java:90)
> at
> org.apache.zookeeper.KeeperException.create(KeeperException.java:42)
> at org.apache.zookeeper.ZooKeeper.exists(ZooKeeper.java:780)
> at
> org.apache.hadoop.hbase.zookeeper.ZKUtil.getNumberOfChildren(ZKUtil.java:495)
> at
> org.apache.hadoop.hbase.client.HTable.getCurrentNrHRS(HTable.java:207)
> at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:182)
> at org.apache.hadoop.hbase.client.HTable.<init>(HTable.java:145)
> at
> com.vng.comment.core.storage.TestHBase.testGet4(TestHBase.java:218)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:616)
> at junit.framework.TestCase.runTest(TestCase.java:168)
> at junit.framework.TestCase.runBare(TestCase.java:134)
> at junit.framework.TestResult$1.protect(TestResult.java:110)
> at junit.framework.TestResult.runProtected(TestResult.java:128)
>
> After change code to
>
> HTable ht = new HTable(config, "T1");
> byte[] row = Bytes.toBytes(1);
>
> Get get = new Get(row);
> Result result = ht.get(get);
> System.out.println(Bytes.
> toString(result.getValue("F1".getBytes(), "C1".getBytes())));
>
> try {
> Thread.sleep(60000);
> } catch (InterruptedException ex) {
> ex.printStackTrace();
> }
> *
> config = new Configuration(false);
> Path hbase = new Path("conf/hbase-site.xml");
> config.addResource(hbase);
> **ht = new HTable(config, "T1");*
>
> get = new Get(row);
> result = ht.get(get);
>
> System.out.println(Bytes.toString(result.getValue("F1".getBytes(),
> "C1".getBytes())));
>
> This code run well.
>
>
> On Fri, Mar 11, 2011 at 9:02 AM, King JKing <beuk...@gmail.com> wrote:
>
>> Here is stacktrace:
>>
>> 11/03/11 08:56:44 WARN zookeeper.ClientCnxn: Exception closing session
>> 0x12ea29ecc580005 to sun.nio.ch.SelectionKeyImpl@1175422
>> java.io.IOException: Read error rc = -1 java.nio.DirectByteBuffer[pos=0
>> lim=4 cap=4]
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.doIO(ClientCnxn.java:701)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:945)
>> 11/03/11 08:56:45 INFO zookeeper.ClientCnxn: Attempting connection to
>> server /10.30.12.182:2181
>> 11/03/11 08:56:45 WARN zookeeper.ClientCnxn: Exception closing session
>> 0x12ea29ecc580005 to sun.nio.ch.SelectionKeyImpl@1b1fbf4
>> java.net.ConnectException: Connection refused
>> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>> at
>> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:592)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:933)
>> 11/03/11 08:56:45 WARN zookeeper.ClientCnxn: Ignoring exception during
>> shutdown input
>> java.nio.channels.ClosedChannelException
>> at
>> sun.nio.ch.SocketChannelImpl.shutdownInput(SocketChannelImpl.java:656)
>> at sun.nio.ch.SocketAdaptor.shutdownInput(SocketAdaptor.java:378)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:999)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:970)
>> 11/03/11 08:56:45 WARN zookeeper.ClientCnxn: Ignoring exception during
>> shutdown output
>> java.nio.channels.ClosedChannelException
>> at
>> sun.nio.ch.SocketChannelImpl.shutdownOutput(SocketChannelImpl.java:667)
>> at sun.nio.ch.SocketAdaptor.shutdownOutput(SocketAdaptor.java:386)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1004)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:970)
>> 11/03/11 08:56:47 INFO zookeeper.ClientCnxn: Attempting connection to
>> server /10.30.12.182:2181
>> 11/03/11 08:56:47 WARN zookeeper.ClientCnxn: Exception closing session
>> 0x12ea29ecc580005 to sun.nio.ch.SelectionKeyImpl@6fa9fc
>> java.net.ConnectException: Connection refused
>> at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>> at
>> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:592)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:933)
>> 11/03/11 08:56:47 WARN zookeeper.ClientCnxn: Ignoring exception during
>> shutdown input
>> java.nio.channels.ClosedChannelException
>> at
>> sun.nio.ch.SocketChannelImpl.shutdownInput(SocketChannelImpl.java:656)
>> at sun.nio.ch.SocketAdaptor.shutdownInput(SocketAdaptor.java:378)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:999)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:970)
>> 11/03/11 08:56:47 WARN zookeeper.ClientCnxn: Ignoring exception during
>> shutdown output
>> java.nio.channels.ClosedChannelException
>> at
>> sun.nio.ch.SocketChannelImpl.shutdownOutput(SocketChannelImpl.java:667)
>> at sun.nio.ch.SocketAdaptor.shutdownOutput(SocketAdaptor.java:386)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.cleanup(ClientCnxn.java:1004)
>> at
>> org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:970)
>>
>>
>>
>> On Thu, Mar 10, 2011 at 9:02 PM, BlueDavy Lin <blued...@gmail.com> wrote:
>>
>>> When u new Get(row) first,HBase client cache the connection to the
>>> appropriate region server,after u restart HBase(I think u run
>>> standalone?),when u do Get(row) again,HBase client still use the
>>> cached connection to do this,so throw the Exception.
>>>
>>> But it seems should not throws the exception a lot of times,can u post
>>> the exception stack?
>>>
>>> 2011/3/10 King JKing <beuk...@gmail.com>:
>>> > Dear all,
>>> >
>>> > When I stop and start HBase server, HTable
>>> (org.apache.hadoop.hbase.client)
>>> > throw exception.
>>> > Here is my code test:
>>> > HTable ht = new HTable(config, "T1");
>>> > byte[] row = Bytes.toBytes(1);
>>> >
>>> > Get get = new Get(row);
>>> > Result result = ht.get(get);
>>> >
>>> > System.out.println(Bytes.toString(result.getValue("F1".getBytes(),
>>> > "C1".getBytes())));
>>> >
>>> > try {
>>> > Thread.sleep(60000);
>>> > } catch (InterruptedException ex) {
>>> > ex.printStackTrace();
>>> > }
>>> >
>>> > get = new Get(row);
>>> > result = ht.get(get);
>>> >
>>> > System.out.println(Bytes.toString(result.getValue("F1".getBytes(),
>>> > "C1".getBytes())));
>>> >
>>> > First I start HBase and run my code. After that I stop and start HBase.
>>> And
>>> > exception "Exception closing session to sun.nio.ch.SelectionKeyImpl"
>>> throws
>>> > a lot of times.
>>> >
>>> > Could you help me to fix this problem?
>>> > Thank a lot for support.
>>> >
>>>
>>>
>>>
>>> --
>>> =============================
>>> | BlueDavy |
>>> | http://www.bluedavy.com |
>>> =============================
>>>
>>
>>
>
