1)Fix bugs. 2)increase MaxDirectMemorySize

Author: yonigottesman

processing/pom.xml

@@ -205,7 +205,7 @@
                     <!-- set default options -->
                     <argLine>
                         -Xmx512m
-                        -XX:MaxDirectMemorySize=1500m
+                        -XX:MaxDirectMemorySize=4g
                         -Duser.language=en
                         -Duser.GroupByQueryRunnerTest.javacountry=US
                         -Dfile.encoding=UTF-8

processing/src/main/java/org/apache/druid/segment/incremental/OakIncrementalIndex.java

@@ -175,7 +175,7 @@ public Row apply(Map.Entry<ByteBuffer, ByteBuffer> entry)
 
     OakMap tmpOakMap = descending ? oak.descendingMap() : oak;
     OakTransformView transformView = tmpOakMap.createTransformView(transformer);
-    OakCloseableIterator<Row> valuesIterator = transformView.valuesIterator();
+    OakCloseableIterator<Row> valuesIterator = transformView.entriesIterator();
     return new Iterable<Row>()
     {
       @Override

processing/src/test/java/org/apache/druid/segment/incremental/OakIncrementalIndexTest.java

@@ -292,10 +292,10 @@ public void testOffHeapOakIncrementalIndexPlainMode() throws Exception
     for (int j = 0; j < insertionTrials; j++) {
       for (int i = 0; i < rows.length; i++) {
         index.add(rows[i]);
-        Assert.assertEquals(index.size(), (j - 1) * rows.length + i + 1);
       }
     }
 
+    Assert.assertEquals(index.size(), 50);
     Iterable<Row> iterable = index.iterableWithPostAggregations(null, false);
     int replicationsCounter = 0;
     Consumer<Row> rowConsumer = new Consumer<Row>() {