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
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 ( 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.)