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
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".