flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Simone Roselli <simonerosell...@gmail.com>
Subject Flume-ng 1.6 - Got an IOException during write
Date Fri, 02 Oct 2015 10:37:04 GMT
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

Mime
View raw message