diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java b/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java index 8b2fc7f5db31e..10594d6c5d340 100644 --- a/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java +++ b/sql/core/src/main/java/org/apache/spark/sql/execution/vectorized/WritableColumnVector.java @@ -72,7 +72,7 @@ public void reset() { numNulls = 0; } - if (hugeVectorThreshold > 0 && capacity > hugeVectorThreshold) { + if (hugeVectorThreshold > -1 && capacity > hugeVectorThreshold) { capacity = defaultCapacity; releaseMemory(); reserveInternal(capacity);