Skip to content
Snippets Groups Projects
Commit d2614eaa authored by Reynold Xin's avatar Reynold Xin
Browse files

[HOTFIX] Fix compilation

parent 18c2c925
No related branches found
No related tags found
No related merge requests found
...@@ -29,7 +29,7 @@ import org.apache.spark.sql.{SparkSession, SQLContext} ...@@ -29,7 +29,7 @@ import org.apache.spark.sql.{SparkSession, SQLContext}
*/ */
@deprecated("Use SparkSession.withHiveSupport instead", "2.0.0") @deprecated("Use SparkSession.withHiveSupport instead", "2.0.0")
class HiveContext private[hive]( class HiveContext private[hive](
@transient private val sparkSession: SparkSession, sparkSession: SparkSession,
isRootContext: Boolean) isRootContext: Boolean)
extends SQLContext(sparkSession, isRootContext) with Logging { extends SQLContext(sparkSession, isRootContext) with Logging {
...@@ -47,15 +47,15 @@ class HiveContext private[hive]( ...@@ -47,15 +47,15 @@ class HiveContext private[hive](
* and Hive client (both of execution and metadata) with existing HiveContext. * and Hive client (both of execution and metadata) with existing HiveContext.
*/ */
override def newSession(): HiveContext = { override def newSession(): HiveContext = {
new HiveContext(sparkSession.newSession(), isRootContext = false) new HiveContext(super.sparkSession.newSession(), isRootContext = false)
} }
protected[sql] override def sessionState: HiveSessionState = { protected[sql] override def sessionState: HiveSessionState = {
sparkSession.sessionState.asInstanceOf[HiveSessionState] super.sparkSession.sessionState.asInstanceOf[HiveSessionState]
} }
protected[sql] override def sharedState: HiveSharedState = { protected[sql] override def sharedState: HiveSharedState = {
sparkSession.sharedState.asInstanceOf[HiveSharedState] super.sparkSession.sharedState.asInstanceOf[HiveSharedState]
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment