Are you sure you need to do table.close() after each put? Looks incorrect. Alex Baranau ------ Sematext :: http://blog.sematext.com/ :: Solr - Lucene - Hadoop - HBase
On Thu, Apr 19, 2012 at 2:48 AM, Marcin Cylke <[email protected]> wrote: > On 17/04/12 18:45, Alex Baranau wrote: > > I don't think that your error is related to CPs stuff. What lib versions > do > > you use? Can you compare with those of the HBaseHUT pom? > > Ok, I've managed to track down the source of my error. If I do normal > Put modifications in my prePut/postPut method everything works ok. The > error occures when I try to make another Put request while in the > prePut/postPut method. > > I'm trying to do this in the following manner: > > HTableInterface table = c.getEnvironment().getTable(tableName); > table.put(createPutRequest(columnFamily, qualifier, "", rowCount)); > table.close(); > > And this gives me the error: > > 2012-04-19 08:43:24,738 [localhost:2222)] INFO ClientCnxn > :933 - Opening socket connection to server localhost/127.0.0.1:2222 > 2012-04-19 08:43:24,739 [localhost:2222)] WARN ClientCnxn > :1063 - Session 0x0 for server null, unexpected error, closing > socket connection and attempting reconnect > java.net.ConnectException: Connection refused > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) > at > sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:567) > at > > org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:286) > at > org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1041) > > > What I'm trying to achieve with adding another Put to my Coprocessor is > to silently update some other row in my hbase table when I need to (when > specific conditions on incoming Put are met) - based on incoming Put > request. Am I misunderstanding the idea here, and should use some other > facility to accomplish the task? > > > Re 127.0.1.1 vs 127.0.0.1 - what your hosts file looked like before and > > now? I think it's just the issue with resolving IP - at one place it > > resolves using localhost, at other - your hostname. Since (I suppose) > those > > two didn't match - you got error. > > Thanks, it is reasonable :) > > > Marcin >
