fix

zml1206 · Jan 14, 2025 · 6f369c9 · 6f369c9
1 parent 48e9475
commit 6f369c9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...talyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RewriteWithExpression.scala b/...talyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/RewriteWithExpression.scala
@@ -82,7 +82,8 @@ object RewriteWithExpression extends Rule[LogicalPlan] {
       if (commonExprs.isEmpty) {
         inputPlan
       } else {
-        Project(inputPlan.output ++ commonExprs.map(_._1), inputPlan)
+        Project(inputPlan.output ++ commonExprs.map(_._1).sortWith(_.exprId.id < _.exprId.id),
+          inputPlan)
       }
     }
     newPlan = newPlan.withNewChildren(newChildren)