fix memleak in sort (#65)

oap-project · Feb 1, 2021 · 9c6dd28 · 9c6dd28
1 parent 9ce64d7
commit 9c6dd28
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/src/main/scala/com/intel/oap/expression/ColumnarSorter.scala b/core/src/main/scala/com/intel/oap/expression/ColumnarSorter.scala
@@ -92,6 +92,8 @@ class ColumnarSorter(
     elapse.set(NANOSECONDS.toMillis(total_elapse))
     sortTime.set(NANOSECONDS.toMillis(sort_elapse))
     shuffleTime.set(NANOSECONDS.toMillis(shuffle_elapse))
+    inputBatchHolder.foreach(cb => cb.close())
+    inputBatchHolder.clear
     if (sorter != null) {
       sorter.close()
     }