Michalis Kongtongk created FLUME-2386:
-----------------------------------------
Summary: Exceptions handing in SyslogTcpSource
Key: FLUME-2386
URL: https://issues.apache.org/jira/browse/FLUME-2386
Project: Flume
Issue Type: Improvement
Affects Versions: v1.4.0
Reporter: Michalis Kongtongk
Priority: Minor
Application is not properly closing the connection eg: we see RST in tcpdump
eg: tcpdump filter: 'tcp[13] & 4!=0'
Flume exceptions are generated in /var/log/flume-ng/flume.init.log instead of
catching them and handling them.
Example:
{noformat}
Apr 10, 2014 11:41:00 AM org.jboss.netty.channel.SimpleChannelHandler
WARNING: EXCEPTION, please implement
org.apache.flume.source.SyslogTcpSource$syslogTcpHandler.exceptionCaught() for
proper handling.
java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcher.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:198)
at sun.nio.ch.IOUtil.read(IOUtil.java:166)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:245)
at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:63)
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.processSelectedKeys(AbstractNioWorker.java:373)
at
org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:247)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:35)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
{noformat}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
