fix bug in sql/hive

chenghao-intel · Jan 3, 2015 · 73c16b1 · 73c16b1
1 parent 9bf4cc7
commit 73c16b1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala
@@ -73,6 +73,9 @@ class LocalHiveContext(sc: SparkContext) extends HiveContext(sc) {
 class HiveContext(sc: SparkContext) extends SQLContext(sc) {
   self =>
 
+  /* By default it should be case insensitive to match Hive */
+  setConf(CatalystConf.CASE_SENSITIVE, "false")
+
   // Change the default SQL dialect to HiveQL
   override private[spark] def dialect: String = getConf(SQLConf.DIALECT, "hiveql")
 
@@ -249,9 +252,6 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
     runSqlHive(s"SET $key=$value")
   }
 
-  /* By default it should be case insensitive to match Hive */
-  this.setConf(CatalystConf.CASE_SENSITIVE, "false")
-
   /* A catalyst metadata catalog that points to the Hive Metastore. */
   @transient
   override protected[sql] lazy val catalog =