Skip to content

Commit

Permalink
Update tests and a param comment.
Browse files Browse the repository at this point in the history
  • Loading branch information
kunalkhamar committed Mar 7, 2017
1 parent 5eb6733 commit 05abcf8
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,8 +48,9 @@ class SessionStateSuite extends SparkFunSuite

test("fork new session and inherit RuntimeConfig options") {
val key = "spark-config-clone"
activeSession.conf.set(key, "active")
try {
activeSession.conf.set(key, "active")

// inheritance
val forkedSession = activeSession.cloneSession()
assert(forkedSession ne activeSession)
Expand Down Expand Up @@ -136,11 +137,11 @@ class SessionStateSuite extends SparkFunSuite
// Cannot use `import activeSession.implicits._` due to the compiler limitation.
import spark.implicits._

activeSession
.createDataset[(Int, String)](Seq(1, 2, 3).map(i => (i, i.toString)))
.toDF("int", "str")
.createOrReplaceTempView("df")
try {
activeSession
.createDataset[(Int, String)](Seq(1, 2, 3).map(i => (i, i.toString)))
.toDF("int", "str")
.createOrReplaceTempView("df")
checkTableExists(activeSession)

val forkedSession = activeSession.cloneSession()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,8 @@ import org.apache.spark.sql.streaming.StreamingQueryManager
* @param conf SQL-specific key-value configurations.
* @param experimentalMethods The experimental methods.
* @param functionRegistry Internal catalog for managing functions registered by the user.
* @param catalog Internal catalog for managing table and database states.
* @param catalog Internal catalog for managing table and database states that uses Hive client for
* interacting with the metastore.
* @param sqlParser Parser that extracts expressions, plans, table identifiers etc. from SQL texts.
* @param metadataHive The Hive metadata client.
* @param analyzer Logical query plan analyzer for resolving unresolved attributes and relations.
Expand Down

0 comments on commit 05abcf8

Please sign in to comment.