aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorReynold Xin <rxin@databricks.com>2016-04-25 21:38:01 -0700
committerReynold Xin <rxin@databricks.com>2016-04-25 21:38:01 -0700
commitf8709218115f6c7aa4fb321865cdef8ceb443bd1 (patch)
tree3144785c8697b23b0163305a45e7b427c68ca760
parentd2614eaadb93a48fba27fe7de64aff942e345f8e (diff)
downloadspark-f8709218115f6c7aa4fb321865cdef8ceb443bd1.tar.gz
spark-f8709218115f6c7aa4fb321865cdef8ceb443bd1.tar.bz2
spark-f8709218115f6c7aa4fb321865cdef8ceb443bd1.zip
[HOTFIX] Fix the problem for real this time.
-rw-r--r--sql/hivecontext-compatibility/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala10
1 files changed, 5 insertions, 5 deletions
diff --git a/sql/hivecontext-compatibility/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala b/sql/hivecontext-compatibility/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala
index bb768979e1..aa0485a891 100644
--- a/sql/hivecontext-compatibility/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala
+++ b/sql/hivecontext-compatibility/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala
@@ -29,9 +29,9 @@ import org.apache.spark.sql.{SparkSession, SQLContext}
*/
@deprecated("Use SparkSession.withHiveSupport instead", "2.0.0")
class HiveContext private[hive](
- sparkSession: SparkSession,
+ _sparkSession: SparkSession,
isRootContext: Boolean)
- extends SQLContext(sparkSession, isRootContext) with Logging {
+ extends SQLContext(_sparkSession, isRootContext) with Logging {
self =>
@@ -47,15 +47,15 @@ class HiveContext private[hive](
* and Hive client (both of execution and metadata) with existing HiveContext.
*/
override def newSession(): HiveContext = {
- new HiveContext(super.sparkSession.newSession(), isRootContext = false)
+ new HiveContext(sparkSession.newSession(), isRootContext = false)
}
protected[sql] override def sessionState: HiveSessionState = {
- super.sparkSession.sessionState.asInstanceOf[HiveSessionState]
+ sparkSession.sessionState.asInstanceOf[HiveSessionState]
}
protected[sql] override def sharedState: HiveSharedState = {
- super.sparkSession.sharedState.asInstanceOf[HiveSharedState]
+ sparkSession.sharedState.asInstanceOf[HiveSharedState]
}
}