more comments

nemccarthy · May 6, 2015 · 1c50813 · 1c50813
1 parent a3bee70
commit 1c50813
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...hriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala b/...hriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala
@@ -147,6 +147,9 @@ private[hive] object SparkSQLCLIDriver {
       case e: UnsupportedEncodingException => System.exit(3)
     }
 
+    // TODO: SET commands seem to be using the wrong session?
+    sessionState.getConf.set("spark.sql.hive.version", HiveShim.version)
+
     if (sessionState.database != null) {
       SparkSQLEnv.hiveContext.runSqlHive(s"USE ${sessionState.database}")
     }

diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/ClientWrapper.scala
@@ -118,6 +118,7 @@ class ClientWrapper(
   /** Returns the configuration for the current session. */
   def conf: HiveConf = SessionState.get().getConf
 
+  // TODO: should be a def?s
   private val client = Hive.get(conf)
 
   /**