Skip to content

Commit 553005a

Browse files
committed
fix test case
1 parent 0c54798 commit 553005a

File tree

1 file changed

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

1 file changed

+6
-5
lines changed

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

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -91,12 +91,13 @@ class Analyzer(
9191
val withAlias = u.alias.map(Subquery(_, relation))
9292
withAlias.getOrElse(relation)
9393
}
94-
substituted.getOrElse(u)
95-
i.copy(table = relation)
94+
i.copy(table = substituted.getOrElse(u))
9695
case u : UnresolvedRelation =>
97-
cteRelations.get(u.tableIdentifier.last)
98-
.map(relation => u.alias.map(Subquery(_, relation)).getOrElse(relation))
99-
.getOrElse(u)
96+
val substituted = cteRelations.get(u.tableIdentifier.last).map { relation =>
97+
val withAlias = u.alias.map(Subquery(_, relation))
98+
withAlias.getOrElse(relation)
99+
}
100+
substituted.getOrElse(u)
100101
}
101102
}
102103
}

0 commit comments

Comments
 (0)