Review Board 1.7.22


FLUME-1490: Option to limit number of events sent in Stress source

Review Request #6673 - Created Aug. 17, 2012 and updated

Patrick Wendell
FLUME-1490
Reviewers
Flume
flume-git
This patch implements a count limit, both for overall (successful + failed) events and for successful events. Seems like both could be useful in testing.
Includes unit test and a bit of code clean-up.
flume-ng-core/pom.xml
Revision 8708953 New Change
[20] 127 lines
[+20]
128
      <artifactId>junit</artifactId>
128
      <artifactId>junit</artifactId>
129
      <scope>test</scope>
129
      <scope>test</scope>
130
    </dependency>
130
    </dependency>
131

    
   
131

   
132
    <dependency>
132
    <dependency>

    
   
133
      <groupId>org.easytesting</groupId>

    
   
134
      <artifactId>fest-reflect</artifactId>

    
   
135
      <version>1.4</version>

    
   
136
      <scope>test</scope>

    
   
137
    </dependency>

    
   
138

   

    
   
139
    <dependency>
133
      <groupId>log4j</groupId>
140
      <groupId>log4j</groupId>
134
      <artifactId>log4j</artifactId>
141
      <artifactId>log4j</artifactId>
135
    </dependency>
142
    </dependency>
136

    
   
143

   
137
    <dependency>
144
    <dependency>
[+20] [20] 43 lines
flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java
Revision 4f7b255 New Change
 
flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java
Revision 579b257 New Change
 
flume-ng-core/src/test/java/org/apache/flume/source/TestStressSource.java
New File
 
  1. flume-ng-core/pom.xml: Loading...
  2. flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java: Loading...
  3. flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java: Loading...
  4. flume-ng-core/src/test/java/org/apache/flume/source/TestStressSource.java: Loading...