Skip to content

Commit

Permalink
Make spark conf a val in SharedSQLContext
Browse files Browse the repository at this point in the history
  • Loading branch information
hvanhovell committed Apr 20, 2017
1 parent c6f62c5 commit 638ac34
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ import org.apache.spark.util.Utils
class FileSourceStrategySuite extends QueryTest with SharedSQLContext with PredicateHelper {
import testImplicits._

protected override val sparkConf = new SparkConf().set("spark.default.parallelism", "1")
protected override def sparkConf = new SparkConf().set("spark.default.parallelism", "1")

test("unpartitioned table, single partition") {
val table =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ import org.apache.spark.sql.test.SharedSQLContext
class CompactibleFileStreamLogSuite extends SparkFunSuite with SharedSQLContext {

/** To avoid caching of FS objects */
override protected val sparkConf =
override protected def sparkConf =
new SparkConf().set(s"spark.hadoop.fs.$scheme.impl.disable.cache", "true")

import CompactibleFileStreamLog._
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ import org.apache.spark.util.UninterruptibleThread
class HDFSMetadataLogSuite extends SparkFunSuite with SharedSQLContext {

/** To avoid caching of FS objects */
override protected val sparkConf =
override protected def sparkConf =
new SparkConf().set(s"spark.hadoop.fs.$scheme.impl.disable.cache", "true")

private implicit def toOption[A](a: A): Option[A] = Option(a)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ import org.apache.spark.sql.internal.SQLConf
*/
trait SharedSQLContext extends SQLTestUtils with BeforeAndAfterEach {

protected val sparkConf = new SparkConf()
protected def sparkConf = new SparkConf()

/**
* The [[TestSparkSession]] to use for all tests in this suite.
Expand Down

0 comments on commit 638ac34

Please sign in to comment.