drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ar...@apache.org
Subject [02/17] drill git commit: DRILL-6205: Reduce memory consumption of testFlattenUpperLimit test
Date Sat, 03 Mar 2018 18:47:08 GMT
DRILL-6205: Reduce memory consumption of testFlattenUpperLimit test

closes #1147


Project: http://git-wip-us.apache.org/repos/asf/drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/41125360
Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/41125360
Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/41125360

Branch: refs/heads/master
Commit: 411253608344343f09f75e15af61e79358da6eb1
Parents: 49faae0
Author: Padma Penumarthy <ppenumar97@yahoo.com>
Authored: Fri Mar 2 11:13:59 2018 -0800
Committer: Arina Ielchiieva <arina.yelchiyeva@gmail.com>
Committed: Sat Mar 3 19:47:33 2018 +0200

----------------------------------------------------------------------
 .../exec/physical/unit/TestOutputBatchSize.java   | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/41125360/exec/java-exec/src/test/java/org/apache/drill/exec/physical/unit/TestOutputBatchSize.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/physical/unit/TestOutputBatchSize.java
b/exec/java-exec/src/test/java/org/apache/drill/exec/physical/unit/TestOutputBatchSize.java
index 99af4c2..741164f 100644
--- a/exec/java-exec/src/test/java/org/apache/drill/exec/physical/unit/TestOutputBatchSize.java
+++ b/exec/java-exec/src/test/java/org/apache/drill/exec/physical/unit/TestOutputBatchSize.java
@@ -656,12 +656,12 @@ public class TestOutputBatchSize extends PhysicalOpUnitTestBase {
 
     batchString.append("[");
 
-    numRows = 1000;
+    numRows = 100;
 
     for (int i = 0; i < numRows; i++) {
-      batchString.append("{\"a\": 5, " + "\"b\" : " + "\"" + wideString + "\"," + "\"c\":"
+ flattenElement + "},");
+      batchString.append("{\"a\": 5, "  + "\"c\":" + flattenElement + "},");
     }
-    batchString.append("{\"a\": 5, " + "\"b\" : " + "\"" + wideString + "\"," + "\"c\":"
+ flattenElement + "}");
+    batchString.append("{\"a\": 5, " + "\"c\":" + flattenElement + "}");
     batchString.append("]");
     inputJsonBatches.add(batchString.toString());
 
@@ -674,18 +674,18 @@ public class TestOutputBatchSize extends PhysicalOpUnitTestBase {
     expectedBatchString.append("[");
     for (int i = 0; i < numRows; i++) {
       for (int j = 0; j < 1000; j++) {
-        expectedBatchString.append("{\"a\": 5, " + "\"b\" : " + "\"" + wideString + "\","
+ "\"c\" :");
+        expectedBatchString.append("{\"a\": 5, "  + "\"c\" :");
         expectedBatchString.append(j);
         expectedBatchString.append("},");
       }
     }
     for (int j = 0; j < 999; j++) {
-      expectedBatchString.append("{\"a\": 5, " + "\"b\" : " + "\"" + wideString + "\"," +
"\"c\" :");
+      expectedBatchString.append("{\"a\": 5, "  + "\"c\" :");
       expectedBatchString.append(j);
       expectedBatchString.append("},");
     }
 
-    expectedBatchString.append("{\"a\": 5, " + "\"b\" : " + "\"" + wideString + "\"," + "\"c\"
:");
+    expectedBatchString.append("{\"a\": 5, "  + "\"c\" :");
     expectedBatchString.append(1000);
     expectedBatchString.append("}");
 
@@ -701,13 +701,13 @@ public class TestOutputBatchSize extends PhysicalOpUnitTestBase {
     OperatorTestBuilder opTestBuilder = opTestBuilder()
       .physicalOperator(flatten)
       .inputDataStreamJson(inputJsonBatches)
-      .baselineColumns("a", "b", "c")
-      .expectedNumBatches(16) // verify number of batches
+      .baselineColumns("a", "c")
+      .expectedNumBatches(2) // verify number of batches
       .expectedBatchSize(totalSize / 2);  // verify batch size.
 
     for (long i = 0; i < numRows + 1; i++) {
       for (long j = 0; j < 1001; j++) {
-        opTestBuilder.baselineValues(5l, wideString, j);
+        opTestBuilder.baselineValues(5l, j);
       }
     }
 


Mime
View raw message