Skip to content

Commit

Permalink
fix typos
Browse files Browse the repository at this point in the history
  • Loading branch information
marmbrus committed May 7, 2015
1 parent 81bb366 commit 5a259f5
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ import org.apache.hadoop.hive.ql.session.SessionState
import org.apache.thrift.transport.TSocket

import org.apache.spark.Logging
import org.apache.spark.sql.hive.HiveShim
import org.apache.spark.sql.hive.{HiveContext, HiveShim}
import org.apache.spark.util.Utils

private[hive] object SparkSQLCLIDriver {
Expand Down Expand Up @@ -81,7 +81,7 @@ private[hive] object SparkSQLCLIDriver {
}
val cliConf = new HiveConf(classOf[SessionState])
// Override the location of the metastore since this is only used for local execution.
HiveContext.newTemporaryConfiguation().foreach {
HiveContext.newTemporaryConfiguration().foreach {
case (key, value) => cliConf.set(key, value)
}
val sessionState = new CliSessionState(cliConf)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
logInfo(s"Initilizing execution hive, version $hiveExecutionVersion")
new ClientWrapper(
version = IsolatedClientLoader.hiveVersion(hiveExecutionVersion),
config = newTemporaryConfiguation())
config = newTemporaryConfiguration())
}
SessionState.setCurrentSessionState(executionHive.state)

Expand Down Expand Up @@ -463,7 +463,7 @@ private[hive] object HiveContext {
val HIVE_METASTORE_JARS: String = "spark.sql.hive.metastore.jars"

/** Constructs a configuration for hive, where the metastore is located in a temp directory. */
def newTemporaryConfiguation(): Map[String, String] = {
def newTemporaryConfiguration(): Map[String, String] = {
val tempDir = Utils.createTempDir()
val localMetastore = new File(tempDir, "metastore")
Map(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ class TestHiveContext(sc: SparkContext) extends HiveContext(sc) {

/** Sets up the system initially or after a RESET command */
protected override def configure(): Map[String, String] =
newTemporaryConfiguation() ++ Map("hive.metastore.warehouse.dir" -> warehousePath.toString)
newTemporaryConfiguration() ++ Map("hive.metastore.warehouse.dir" -> warehousePath.toString)

val testTempDir = Utils.createTempDir()

Expand Down

0 comments on commit 5a259f5

Please sign in to comment.