[prev in list] [next in list] [prev in thread] [next in thread] 

List:       flume-user
Subject:    Flume-ng 1.6 - Got an IOException during write
From:       Simone Roselli <simoneroselli78 () gmail ! com>
Date:       2015-10-02 10:37:04
Message-ID: CAH34K+kt5k+RfiQ+pwUdw50oNgX6AMVB+apNbo9-MJAwA1C9EA () mail ! gmail ! com
[Download RAW message or body]

Hi,

I get this warning from the Thrift source on a file-channel configuration:

WARN  [Thread-2]
(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:488)
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.TThreadedSelectorServer$SelectorThread.select(TThreadedSelectorServer.java:579)
 at
org.apache.thrift.server.TThreadedSelectorServer$SelectorThread.run(TThreadedSelectorServer.java:536)


I don't fully understand whether this could come from any wrong
configuration

# Channel configuration
agent1.channels.ch1.type = file
agent1.channels.ch1.checkpointDir = /opt/flume-ng/chekpoint
agent1.channels.ch1.dataDirs = /opt/flume-ng/data

# Source
agent1.sources.thriftSrc.type = thrift
agent1.sources.thriftSrc.channels = ch1
agent1.sources.thriftSrc.bind = 0.0.0.0
agent1.sources.thriftSrc.port = 4042


Thanks
Simone


[Attachment #3 (text/html)]

<div dir="ltr">Hi,<div><br></div><div>I get this warning from the Thrift source on a \
file-channel configuration:</div><div><br></div><div><div>WARN   [Thread-2] \
(org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.write:385)   - Got an \
IOException during write!</div><div>java.io.IOException: Broken pipe</div><div><span \
class="" style="white-space:pre">	</span>at \
sun.nio.ch.FileDispatcherImpl.write0(Native Method)</div><div><span class="" \
style="white-space:pre">	</span>at \
sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47)</div><div><span class="" \
style="white-space:pre">	</span>at \
sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)</div><div><span class="" \
style="white-space:pre">	</span>at \
sun.nio.ch.IOUtil.write(IOUtil.java:65)</div><div><span class="" \
style="white-space:pre">	</span>at \
sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:488)</div><div><span \
class="" style="white-space:pre">	</span>at \
org.apache.thrift.transport.TNonblockingSocket.write(TNonblockingSocket.java:164)</div><div><span \
class="" style="white-space:pre">	</span>at \
org.apache.thrift.server.AbstractNonblockingServer$FrameBuffer.write(AbstractNonblockingServer.java:381)</div><div><span \
class="" style="white-space:pre">	</span>at \
org.apache.thrift.server.AbstractNonblockingServer$AbstractSelectThread.handleWrite(AbstractNonblockingServer.java:220)</div><div><span \
class="" style="white-space:pre">	</span>at \
org.apache.thrift.server.TThreadedSelectorServer$SelectorThread.select(TThreadedSelectorServer.java:579)</div><div><span \
class="" style="white-space:pre">	</span>at \
org.apache.thrift.server.TThreadedSelectorServer$SelectorThread.run(TThreadedSelectorServer.java:536)</div></div><div><br></div><div>I \
don&#39;t fully understand whether this could come from any wrong \
configuration</div><div><br></div><div># Channel \
configuration</div><div><div>agent1.channels.ch1.type = \
file</div><div>agent1.channels.ch1.checkpointDir = \
/opt/flume-ng/chekpoint</div><div>agent1.channels.ch1.dataDirs = \
/opt/flume-ng/data</div></div><div><br></div><div># \
Source</div><div><div>agent1.sources.thriftSrc.type = \
thrift</div><div>agent1.sources.thriftSrc.channels = \
ch1</div><div>agent1.sources.thriftSrc.bind = \
0.0.0.0</div><div>agent1.sources.thriftSrc.port = \
4042</div></div><div><br></div><div><br></div><div>Thanks</div><div>Simone</div></div>




[prev in list] [next in list] [prev in thread] [next in thread]