-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34200/
-----------------------------------------------------------
(Updated 七月 26, 2016, 8:30 a.m.)
Review request for Flume.
Changes
-------
Expanded this import and added unit test.
Bugs: FLUME-2689
https://issues.apache.org/jira/browse/FLUME-2689
Repository: flume-git
Description
-------
Reloading conf file will stop old syslog source and start new syslog source.
Stopping syslog tcp source only closes the NioServerSocketChannel, resulting in
the client sends data through the old channel. In that case, the new source
never receives data. The tcpdump shows the events have received but the new
source doesn't and ss shows the client connection stays same with old one.
The right way to stop syslog source is close both the NioSocketChannel and
NioServerSocketChannel, and shutdown the executor.
Diffs (updated)
-----
flume-ng-core/src/main/java/org/apache/flume/source/SyslogTcpSource.java
e84e4b6
flume-ng-core/src/test/java/org/apache/flume/source/TestSyslogTcpSource.java
22fa200
Diff: https://reviews.apache.org/r/34200/diff/
Testing
-------
Thanks,
wei yang
