File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -799,7 +799,6 @@ class Analyzer(
799
799
* Replaces [[UnresolvedRelation ]]s with concrete relations from the catalog.
800
800
*/
801
801
object ResolveRelations extends Rule [LogicalPlan ] {
802
- private val relationToLogicalPlanMaps = AnalysisContext .get.relationToLogicalPlanMaps
803
802
804
803
// If an unresolved relation is given, it is looked up from the session catalog and either v1
805
804
// or v2 relation is returned. Otherwise, we look up the table from catalog
@@ -867,6 +866,7 @@ class Analyzer(
867
866
}
868
867
869
868
case u : UnresolvedRelation =>
869
+ val relationToLogicalPlanMaps = AnalysisContext .get.relationToLogicalPlanMaps
870
870
relationToLogicalPlanMaps.getOrElse(u, {
871
871
val relation = resolveRelation(u)
872
872
relationToLogicalPlanMaps.update(u, relation)
You can’t perform that action at this time.
0 commit comments