From d6eb459dbd7d63c9d9c6b8bc1c71033105e6fa84 Mon Sep 17 00:00:00 2001
From: Rui Mo <rui.mo@intel.com>
Date: Thu, 28 Jan 2021 05:59:48 +0000
Subject: [PATCH] fix memleak in sort

---
 .../main/scala/com/intel/oap/expression/ColumnarSorter.scala    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/core/src/main/scala/com/intel/oap/expression/ColumnarSorter.scala b/core/src/main/scala/com/intel/oap/expression/ColumnarSorter.scala
index b78d0e17b..549386f6b 100644
--- 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()
     }