Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Flume >> mail # dev >> Review Request: Support for batch size in StressSource


Copy link to this message
-
Review Request: Support for batch size in StressSource

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/6949/
-----------------------------------------------------------

Review request for Flume.
Description
-------

Adding batchSize to StressSource along with junit to test it.  

Important note: the total number of events getting sent will equals maxTotalEvents, so if maxTotalEvents is not devisable by batchSize then the last batch will contain only the remainder of events needed to reach maxTotalEvents.
This addresses bug FLUME-1536.
    https://issues.apache.org/jira/browse/FLUME-1536
Diffs
-----

  flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java 5b73910
  flume-ng-core/src/test/java/org/apache/flume/source/TestStressSource.java 4ec16c7

Diff: https://reviews.apache.org/r/6949/diff/
Testing
-------
Thanks,

Ted Malaska