Minor fix

Nathan Speidel · Nathan Speidel · commit c0bad2d1c779 · 2018-03-19T15:48:56.000-07:00
diff --git a/examples/storm/src/main/java/com/yahoo/bullet/storm/examples/RandomSpout.java b/examples/storm/src/main/java/com/yahoo/bullet/storm/examples/RandomSpout.java
@@ -120,6 +120,7 @@ public void nextTuple() {
         if (timeNow <= nextIntervalStart && generatedThisPeriod < maxPerPeriod) {
             outputCollector.emit(new Values(generateRecord()), DUMMY_ID);
             generatedThisPeriod++;
+            return;
         }
         if (timeNow > nextIntervalStart) {
             log.info("Generated {} tuples out of {}", generatedThisPeriod, maxPerPeriod);

Original file line number	Diff line number	Diff line change
`@@ -120,6 +120,7 @@ public void nextTuple() {`
`120`	`120`	`if (timeNow <= nextIntervalStart && generatedThisPeriod < maxPerPeriod) {`
`121`	`121`	`outputCollector.emit(new Values(generateRecord()), DUMMY_ID);`
`122`	`122`	`generatedThisPeriod++;`
	`123`	`+ return;`
`123`	`124`	`}`
`124`	`125`	`if (timeNow > nextIntervalStart) {`
`125`	`126`	`log.info("Generated {} tuples out of {}", generatedThisPeriod, maxPerPeriod);`