diff options
Diffstat (limited to 'sql/core/src/main/scala/org/apache')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala index ddcae0fe07..35228643a5 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala @@ -51,7 +51,10 @@ class QueryExecution(val sqlContext: SQLContext, val logical: LogicalPlan) { } } - lazy val analyzed: LogicalPlan = sqlContext.sessionState.analyzer.execute(logical) + lazy val analyzed: LogicalPlan = { + SQLContext.setActive(sqlContext) + sqlContext.sessionState.analyzer.execute(logical) + } lazy val withCachedData: LogicalPlan = { assertAnalyzed() |