accumulo-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "mohit.kaushik" <>
Subject Re: IOException in internalRead! & transient exception communicating with ZooKeeper
Date Mon, 22 Feb 2016 06:53:08 GMT
Sent so early...

Another exception I am getting frequently with zookeeper which is a 
bigger problem.
ACCUMULO-3336 <> says 
it is unresolved yet

Saw (possibly) transient exception communicating with ZooKeeper
	org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss
for /accumulo/f8708e0d-9238-41f5-b948-8f435fd01207/gc/lock
		at org.apache.zookeeper.KeeperException.create(
		at org.apache.zookeeper.KeeperException.create(
		at org.apache.zookeeper.ZooKeeper.exists(
		at org.apache.accumulo.fate.zookeeper.ZooReader.getStatus(
		at org.apache.accumulo.fate.zookeeper.ZooLock.process(
		at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(
		at org.apache.zookeeper.ClientCnxn$

And the worst case is whenever a zookeeper goes down cluster becomes 
unreacheble for the time being, untill it restarts ingest process halts.

What do you suggest, I need to resolve these problems. I do not want to 
be the ingest process to stop ever.

Mohit kaushik

On 02/22/2016 12:06 PM, mohit.kaushik wrote:
> I am facing the below given exception continuously, the count keeps on increasing every
sec(current value around 3000 on a server) I can see the exception for all 3 tablet servers.
> ACCUMULO-2420  <>  says that
this exception comes when a client closes a connection before scan completes. But the connection
is not closed every thread uses a common connection object to ingest and query, then what
could cause this exception?
> Connection reset by peer
> 		at Method)
> 		at
> 		at
> 		at
> 		at
> 		at
> 		at org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.internalRead(
> 		at org.apache.thrift.server.AbstractNonblockingServer$
> 		at org.apache.thrift.server.AbstractNonblockingServer$AbstractSelectThread.handleRead(
> 		at org.apache.accumulo.server.rpc.CustomNonBlockingServer$
> 		at org.apache.accumulo.server.rpc.CustomNonBlockingServer$
> Regards
> Mohit kaushik
> Signature

View raw message