diff --git a/core/src/main/scala/com/intel/oap/expression/ColumnarSortMergeJoin.scala b/core/src/main/scala/com/intel/oap/expression/ColumnarSortMergeJoin.scala
index 7447e4b2c..b01dd688b 100644
--- a/core/src/main/scala/com/intel/oap/expression/ColumnarSortMergeJoin.scala
+++ b/core/src/main/scala/com/intel/oap/expression/ColumnarSortMergeJoin.scala
@@ -233,6 +233,10 @@ object ColumnarSortMergeJoin extends Logging {
     val lkeyProjectOrdinalList = new ListBuffer[Int]()
     val lkeyFieldList: List[Field] = leftKeys.toList.zipWithIndex.map {
       case (expr, i) => {
+        //TODO(): fix this workaround
+        if (expr.isInstanceOf[AttributeReference] && expr.asInstanceOf[AttributeReference].name == "none") {
+          return
+        }
         val (nativeNode, returnType) = ConverterUtils.getColumnarFuncNode(expr)
         if (s"${nativeNode.toProtobuf}".contains("none#")) {
           throw new UnsupportedOperationException(
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 a0ecd638f..0fe9b0389 100644
--- a/core/src/main/scala/com/intel/oap/expression/ColumnarSorter.scala
+++ b/core/src/main/scala/com/intel/oap/expression/ColumnarSorter.scala
@@ -157,7 +157,8 @@ class ColumnarSorter(
           has_next = sort_iterator.hasNext()
 
         if (has_next == false) {
-          close()
+          //TODO(): should try to close sorter
+          //close()
         }
 
         return has_next