Merge pull request #2348 from AlexanderSaydakov/fix-aggregator-test-helper

fixed createIndex

processing/src/test/java/io/druid/query/aggregation/AggregationTestHelper.java

@@ -314,22 +314,20 @@ public class AggregationTestHelper
       index = new OnheapIncrementalIndex(minTimestamp, gran, metrics, deserializeComplexMetrics, maxRowCount);
       while (rows.hasNext()) {
         Object row = rows.next();
-        try {
+        if (!index.canAppendRow()) {
-          if (row instanceof String && parser instanceof StringInputRowParser) {
-            //Note: this is required because StringInputRowParser is InputRowParser<ByteBuffer> as opposed to
-            //InputRowsParser<String>
-            index.add(((StringInputRowParser) parser).parse((String) row));
-          } else {
-            index.add(parser.parse(row));
-          }
-        }
-        catch (IndexSizeExceededException ex) {
           File tmp = tempFolder.newFolder();
           toMerge.add(tmp);
           indexMerger.persist(index, tmp, new IndexSpec());
           index.close();
           index = new OnheapIncrementalIndex(minTimestamp, gran, metrics, deserializeComplexMetrics, maxRowCount);
         }
+        if (row instanceof String && parser instanceof StringInputRowParser) {
+          //Note: this is required because StringInputRowParser is InputRowParser<ByteBuffer> as opposed to
+          //InputRowsParser<String>
+          index.add(((StringInputRowParser) parser).parse((String) row));
+        } else {
+          index.add(parser.parse(row));
+        }
       }
 
       if (toMerge.size() > 0) {