Skip to content

Commit 13aef71

Browse files
committed
fix trimAliases
1 parent a306465 commit 13aef71

File tree

1 file changed

+3
-3
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis

1 file changed

+3
-3
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2543,9 +2543,9 @@ object EliminateUnions extends Rule[LogicalPlan] {
25432543
*/
25442544
object CleanupAliases extends Rule[LogicalPlan] {
25452545
private[catalyst] def trimAliases(e: Expression): Expression = {
2546-
e.transformDown {
2547-
case Alias(child, _) => trimAliases(child)
2548-
case MultiAlias(child, _) => trimAliases(child)
2546+
e.transformUp {
2547+
case Alias(child, _) => child
2548+
case MultiAlias(child, _) => child
25492549
}
25502550
}
25512551

0 commit comments

Comments
 (0)