Issues with ScribeSource

[vivek thakre <vi...@gmail.com>]

Hello,

I am using 1.6 and this is how my Flume agent is configured.
ScribeSorce->FileChannel->KafkaSink

I keep getting following error periodically (pasted below)
I am not sure whats the cause of this error.

Has anyone encountered this error before?
Let me know if you want more details.

Thanks

09 Jul 2015 22:22:54,223 WARN  [Thread-744]
(org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.write:385)
- Got an IOException during write!

java.io.IOException: Broken pipe

at sun.nio.ch.FileDispatcherImpl.write0(Native Method)

at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47)

at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)

at sun.nio.ch.IOUtil.write(IOUtil.java:65)

at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:487)

at
org.apache.thrift.transport.TNonblockingSocket.write(TNonblockingSocket.java:164)

at
org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.write(AbstractNonblockingServer.java:381)

at
org.apache.thrift.server.AbstractNonblockingServer$AbstractSelectThread.handleWrite(AbstractNonblockingServer.java:220)

at
org.apache.thrift.server.TNonblockingServer$SelectAcceptThread.select(TNonblockingServer.java:201)

at
org.apache.thrift.server.TNonblockingServer$SelectAcceptThread.run(TNonblockingServer.java:154)
and also

09 Jul 2015 22:23:38,658 WARN  [Thread-744]
(org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.internalRead:520)
- 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:223)

at sun.nio.ch.IOUtil.read(IOUtil.java:197)

at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379)

at
org.apache.thrift.transport.TNonblockingSocket.read(TNonblockingSocket.java:141)

at
org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.internalRead(AbstractNonblockingServer.java:515)

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)