Skip to content

Commit 29aaaaf

Browse files
committed
fix compile
1 parent 1c9a092 commit 29aaaaf

File tree

1 file changed

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

1 file changed

+2
-8
lines changed

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

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -46,11 +46,6 @@ class Analyzer(
4646
val resolver = if (caseSensitive) caseSensitiveResolution else caseInsensitiveResolution
4747

4848
val fixedPoint = FixedPoint(maxIterations)
49-
50-
/**
51-
* Override to provide additional rules for the "Substitution" batch.
52-
*/
53-
val extendedSubstitutionRules: Seq[Rule[LogicalPlan]] = Nil
5449

5550
/**
5651
* Override to provide additional rules for the "Resolution" batch.
@@ -60,8 +55,7 @@ class Analyzer(
6055
lazy val batches: Seq[Batch] = Seq(
6156
Batch("Substitution", fixedPoint,
6257
CTESubstitution ::
63-
Nil ++
64-
extendedSubstitutionRules : _*),
58+
Nil : _*),
6559
Batch("Resolution", fixedPoint,
6660
ResolveRelations ::
6761
ResolveReferences ::
@@ -223,7 +217,7 @@ class Analyzer(
223217
case i@InsertIntoTable(u: UnresolvedRelation, _, _, _, _) =>
224218
i.copy(table = EliminateSubQueries(getTable(u)))
225219
case u: UnresolvedRelation =>
226-
getTable(u, cteRelations)
220+
getTable(u)
227221
}
228222
}
229223

0 commit comments

Comments
 (0)