Skip to content

Commit 73c16b1

Browse files
author
Jacky Li
committed
fix bug in sql/hive
1 parent 9bf4cc7 commit 73c16b1

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,9 @@ class LocalHiveContext(sc: SparkContext) extends HiveContext(sc) {
7373
class HiveContext(sc: SparkContext) extends SQLContext(sc) {
7474
self =>
7575

76+
/* By default it should be case insensitive to match Hive */
77+
setConf(CatalystConf.CASE_SENSITIVE, "false")
78+
7679
// Change the default SQL dialect to HiveQL
7780
override private[spark] def dialect: String = getConf(SQLConf.DIALECT, "hiveql")
7881

@@ -249,9 +252,6 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
249252
runSqlHive(s"SET $key=$value")
250253
}
251254

252-
/* By default it should be case insensitive to match Hive */
253-
this.setConf(CatalystConf.CASE_SENSITIVE, "false")
254-
255255
/* A catalyst metadata catalog that points to the Hive Metastore. */
256256
@transient
257257
override protected[sql] lazy val catalog =

0 commit comments

Comments
 (0)