File tree Expand file tree Collapse file tree 2 files changed +3
-4
lines changed
catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis
hive/src/main/scala/org/apache/spark/sql/hive/test Expand file tree Collapse file tree 2 files changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -126,9 +126,7 @@ class Analyzer(
126126 }
127127 }
128128
129- private def executeSameContext (plan : LogicalPlan ): LogicalPlan = {
130- super .execute(plan)
131- }
129+ private def executeSameContext (plan : LogicalPlan ): LogicalPlan = super .execute(plan)
132130
133131 def resolver : Resolver = conf.resolver
134132
Original file line number Diff line number Diff line change @@ -34,6 +34,7 @@ import org.apache.hadoop.hive.serde2.`lazy`.LazySimpleSerDe
3434import org .apache .spark .{SparkConf , SparkContext }
3535import org .apache .spark .internal .Logging
3636import org .apache .spark .sql .{SparkSession , SQLContext }
37+ import org .apache .spark .sql .catalyst .QueryPlanningTracker
3738import org .apache .spark .sql .catalyst .analysis .UnresolvedRelation
3839import org .apache .spark .sql .catalyst .catalog .{ExternalCatalog , ExternalCatalogWithListener }
3940import org .apache .spark .sql .catalyst .optimizer .ConvertToLocalRelation
@@ -586,7 +587,7 @@ private[hive] class TestHiveQueryExecution(
586587 logDebug(s " Query references test tables: ${referencedTestTables.mkString(" , " )}" )
587588 referencedTestTables.foreach(sparkSession.loadTestTable)
588589 // Proceed with analysis.
589- sparkSession.sessionState.analyzer.executeAndCheck(logical, None )
590+ sparkSession.sessionState.analyzer.executeAndCheck(logical, new QueryPlanningTracker )
590591 }
591592}
592593
You can’t perform that action at this time.
0 commit comments