fix

apache · Jul 2, 2024 · f645924 · f645924
1 parent b6597de
commit f645924
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/gluten-core/src/main/scala/org/apache/gluten/extension/columnar/OffloadSingleNode.scala b/gluten-core/src/main/scala/org/apache/gluten/extension/columnar/OffloadSingleNode.scala
@@ -369,13 +369,13 @@ case class OffloadWindow() extends OffloadSingleNode with LogLevelUtil {
   private val replace = new ReplaceSingleNode()
 
   override def offload(plan: SparkPlan): SparkPlan = plan match {
-    case window: WindowExec =>
+    case window: WindowExec if BackendsApiManager.getSettings.requiredChildOrderingForWindow() =>
       if (TransformHints.isNotTransformable(window)) {
         return window
       }
 
-      val transformer = replace.doReplace(window)
-      val newChild = transformer.children.head match {
+      val transformer = replace.doReplace(window).asInstanceOf[UnaryTransformSupport]
+      val newChild = transformer.child match {
         case SortExec(_, false, child, _)
             if outputOrderSatisfied(child, transformer.requiredChildOrdering.head) =>
           child