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
