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 <[email protected]> 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?
