diff --git a/native-sql-engine/core/src/main/scala/com/intel/oap/extension/ColumnarOverrides.scala b/native-sql-engine/core/src/main/scala/com/intel/oap/extension/ColumnarOverrides.scala index 71c2fbda4..9a0410d6d 100644 --- a/native-sql-engine/core/src/main/scala/com/intel/oap/extension/ColumnarOverrides.scala +++ b/native-sql-engine/core/src/main/scala/com/intel/oap/extension/ColumnarOverrides.scala @@ -162,6 +162,10 @@ case class ColumnarPreOverrides() extends Rule[SparkPlan] { case plan: SortExec => val child = replaceWithColumnarPlan(plan.child) logDebug(s"Columnar Processing for ${plan.getClass} is currently supported.") + if (child.isInstanceOf[ExpandExec]) { + //FIXME: quick for Sort spill bug + return plan.withNewChildren(Seq(child)) + } child match { case p: CoalesceBatchesExec => ColumnarSortExec(plan.sortOrder, plan.global, p.child, plan.testSpillFrequency)