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 <[email protected]> Authored: Fri Mar 2 11:13:59 2018 -0800 Committer: Arina Ielchiieva <[email protected]> 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); } }
