You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2016/04/20 23:26:10 UTC
spark git commit: [SPARK-14749][SQL,
TESTS] PlannerSuite failed when it run individually
Repository: spark
Updated Branches:
refs/heads/master e7791c4f6 -> fd8268194
[SPARK-14749][SQL, TESTS] PlannerSuite failed when it run individually
## What changes were proposed in this pull request?
3 testcases namely,
```
"count is partially aggregated"
"count distinct is partially aggregated"
"mixed aggregates are partially aggregated"
```
were failing when running PlannerSuite individually.
The PR provides a fix for this.
## How was this patch tested?
unit tests
(If this patch involves UI changes, please attach a screenshot; otherwise, remove this)
Author: Subhobrata Dey <sb...@gmail.com>
Closes #12532 from sbcd90/plannersuitetestsfix.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/fd826819
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/fd826819
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/fd826819
Branch: refs/heads/master
Commit: fd82681945447d97df368bcdcd112b08bd541cca
Parents: e7791c4
Author: Subhobrata Dey <sb...@gmail.com>
Authored: Wed Apr 20 14:26:07 2016 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Wed Apr 20 14:26:07 2016 -0700
----------------------------------------------------------------------
.../scala/org/apache/spark/sql/execution/QueryExecution.scala | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/fd826819/sql/core/src/main/scala/org/apache/spark/sql/execution/QueryExecution.scala
----------------------------------------------------------------------
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 ddcae0f..3522864 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()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org