Skip to content

Commit 1ce8a5e

Browse files
Invoke runSqlHive() in SQLConf#get for the HiveContext case.
1 parent b766af9 commit 1ce8a5e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
132132
@transient protected[hive] lazy val hiveconf = new HiveConf(classOf[SessionState])
133133
@transient override lazy val sqlConf: SQLConf = new SQLConf(hiveconf.getAllProperties) {
134134
override def set(key: String, value: String): SQLConf = {
135-
hiveconf.set(key, value)
135+
runSqlHive(s"SET $key=$value")
136136
settings(key) = value
137137
this
138138
}

0 commit comments

Comments
 (0)