fix recursive aliases

mgaido91 · mgaido91 · commit a306465d3fc0 · 2018-11-29T12:10:47.000+01:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
@@ -2544,8 +2544,8 @@ object EliminateUnions extends Rule[LogicalPlan] {
 object CleanupAliases extends Rule[LogicalPlan] {
   private[catalyst] def trimAliases(e: Expression): Expression = {
     e.transformDown {
-      case Alias(child, _) => child
-      case MultiAlias(child, _) => child
+      case Alias(child, _) => trimAliases(child)
+      case MultiAlias(child, _) => trimAliases(child)
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -2544,8 +2544,8 @@ object EliminateUnions extends Rule[LogicalPlan] {`
`2544`	`2544`	`object CleanupAliases extends Rule[LogicalPlan] {`
`2545`	`2545`	`private[catalyst] def trimAliases(e: Expression): Expression = {`
`2546`	`2546`	`e.transformDown {`
`2547`		`- case Alias(child, _) => child`
`2548`		`- case MultiAlias(child, _) => child`
	`2547`	`+ case Alias(child, _) => trimAliases(child)`
	`2548`	`+ case MultiAlias(child, _) => trimAliases(child)`
`2549`	`2549`	`}`
`2550`	`2550`	`}`
`2551`	`2551`