[server.THsHaServer] WARN : Got an IOException in internalRead!

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

[server.THsHaServer] WARN : Got an IOException in internalRead!

David Medinets
I ran this Java code and got an exception in my logs. Although there
was no exception thrown by the Java program.

                String instanceName = "development";
                String zooKeepers = "zookeeper.affy.com";
                String user = "root";
                byte[] pass = "....".getBytes();

                ZooKeeperInstance instance = new ZooKeeperInstance(instanceName, zooKeepers);
                instance.getConnector(user, pass);

14 00:07:53,191 [server.THsHaServer] WARN : Got an IOException in internalRead!
java.io.IOException: Connection reset by peer
        at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:218)
        at sun.nio.ch.IOUtil.read(IOUtil.java:191)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:359)
        at org.apache.thrift.transport.TNonblockingSocket.read(TNonblockingSocket.java:141)
        at org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.internalRead(AbstractNonblockingServer.java:514)
        at org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.read(AbstractNonblockingServer.java:305)
        at org.apache.thrift.server.AbstractNonblockingServer$AbstractSelectThread.handleRead(AbstractNonblockingServer.java:202)
        at org.apache.thrift.server.TNonblockingServer$SelectAcceptThread.select(TNonblockingServer.java:198)
        at org.apache.thrift.server.TNonblockingServer$SelectAcceptThread.run(TNonblockingServer.java:154)

Any ideas?
Reply | Threaded
Open this post in threaded view
|

Re: [server.THsHaServer] WARN : Got an IOException in internalRead!

David Medinets
More information about this issue. I don't see this error when I
insert from the Accumulo shell. And it only happens once per client
connection. I've tried to insert multiple mutations, to use multiple
MultiTableBatchWriter, and connectors and ZooKeeperInstance. For each
permutation, one exception was thrown.

Mentions on the web include:
  https://issues.apache.org/jira/browse/HBASE-1367
  https://issues.apache.org/jira/browse/HAMA-507

I don't see any thoughts about what the underlying problem is or how
to correct whatever is wrong.

On Fri, Jul 13, 2012 at 8:16 PM, David Medinets
<[hidden email]> wrote:

> I ran this Java code and got an exception in my logs. Although there
> was no exception thrown by the Java program.
>
>                 String instanceName = "development";
>                 String zooKeepers = "zookeeper.affy.com";
>                 String user = "root";
>                 byte[] pass = "....".getBytes();
>
>                 ZooKeeperInstance instance = new ZooKeeperInstance(instanceName, zooKeepers);
>                 instance.getConnector(user, pass);
>
> 14 00:07:53,191 [server.THsHaServer] WARN : Got an IOException in internalRead!
> java.io.IOException: Connection reset by peer
>         at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
>         at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
>         at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:218)
>         at sun.nio.ch.IOUtil.read(IOUtil.java:191)
>         at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:359)
>         at org.apache.thrift.transport.TNonblockingSocket.read(TNonblockingSocket.java:141)
>         at org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.internalRead(AbstractNonblockingServer.java:514)
>         at org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.read(AbstractNonblockingServer.java:305)
>         at org.apache.thrift.server.AbstractNonblockingServer$AbstractSelectThread.handleRead(AbstractNonblockingServer.java:202)
>         at org.apache.thrift.server.TNonblockingServer$SelectAcceptThread.select(TNonblockingServer.java:198)
>         at org.apache.thrift.server.TNonblockingServer$SelectAcceptThread.run(TNonblockingServer.java:154)
>
> Any ideas?