Skip to content

Commit 638ac34

Browse files
committed
Make spark conf a val in SharedSQLContext
1 parent c6f62c5 commit 638ac34

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/FileSourceStrategySuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ import org.apache.spark.util.Utils
4242
class FileSourceStrategySuite extends QueryTest with SharedSQLContext with PredicateHelper {
4343
import testImplicits._
4444

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

4747
test("unpartitioned table, single partition") {
4848
val table =

sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/CompactibleFileStreamLogSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ import org.apache.spark.sql.test.SharedSQLContext
2828
class CompactibleFileStreamLogSuite extends SparkFunSuite with SharedSQLContext {
2929

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

3434
import CompactibleFileStreamLog._

sql/core/src/test/scala/org/apache/spark/sql/execution/streaming/HDFSMetadataLogSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ import org.apache.spark.util.UninterruptibleThread
3838
class HDFSMetadataLogSuite extends SparkFunSuite with SharedSQLContext {
3939

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

4444
private implicit def toOption[A](a: A): Option[A] = Option(a)

sql/core/src/test/scala/org/apache/spark/sql/test/SharedSQLContext.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ import org.apache.spark.sql.internal.SQLConf
2929
*/
3030
trait SharedSQLContext extends SQLTestUtils with BeforeAndAfterEach {
3131

32-
protected val sparkConf = new SparkConf()
32+
protected def sparkConf = new SparkConf()
3333

3434
/**
3535
* The [[TestSparkSession]] to use for all tests in this suite.

0 commit comments

Comments
 (0)