Review Board 1.7.22


ExecSource don't flush the buffer if there are no input events and the batch size has not reached

Review Request #10632 - Created April 19, 2013 and updated

Venkatesh Sivasubramanian
Trunk/1.4
FLUME-1819
Reviewers
Flume
Flume
The Fix is to add "batchTimeout" Property for ExecSource (default is 3 seconds). if batchTimeout exceeded, ExecSource will push all buffered data to the channel even is the batch size was not reached.

Pls. see the Jira issue (https://issues.apache.org/jira/browse/FLUME-1819) for more details.

1. Added a Unit Test case to the class TestExecSource class.
2. Tested with a flume agent locally. I setup source as a "tail -f <file>" command, used as in-memory channel and the Sink as "logger". 
Ship it!
Posted (April 19, 2013, 8:54 p.m.)
+1