In LimitRecordBatch, free incoming batch mem when upstream outcome is…

… NONE.
apache · Dec 23, 2022 · 5cee148 · 5cee148
1 parent eae8d48
commit 5cee148
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/limit/LimitRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/limit/LimitRecordBatch.java
@@ -75,7 +75,7 @@ public IterOutcome innerNext() {
         upStream = next(incoming);
       }
       // If EMIT that means leaf operator is UNNEST, in this case refresh the limit states and return EMIT.
-      if (upStream == EMIT) {
+      if (upStream == EMIT || upStream == NONE) {
         // Clear the memory for the incoming batch
         VectorAccessibleUtilities.clear(incoming);