Skip to content

Commit 9a279a3

Browse files
committed
Rename spark -> sparkSession in DataSourceReadBenchmark
1 parent 9267efc commit 9a279a3

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/DataSourceReadBenchmark.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -54,14 +54,14 @@ object DataSourceReadBenchmark extends SqlBasedBenchmark {
5454
.setIfMissing("spark.executor.memory", "3g")
5555
.setIfMissing(UI_ENABLED, false)
5656

57-
val spark = SparkSession.builder.config(conf).getOrCreate()
57+
val sparkSession = SparkSession.builder.config(conf).getOrCreate()
5858

5959
// Set default configs. Individual cases will change them if necessary.
60-
spark.conf.set(SQLConf.ORC_FILTER_PUSHDOWN_ENABLED.key, "true")
61-
spark.conf.set(SQLConf.PARQUET_VECTORIZED_READER_ENABLED.key, "true")
62-
spark.conf.set(SQLConf.WHOLESTAGE_CODEGEN_ENABLED.key, "true")
60+
sparkSession.conf.set(SQLConf.ORC_FILTER_PUSHDOWN_ENABLED.key, "true")
61+
sparkSession.conf.set(SQLConf.PARQUET_VECTORIZED_READER_ENABLED.key, "true")
62+
sparkSession.conf.set(SQLConf.WHOLESTAGE_CODEGEN_ENABLED.key, "true")
6363

64-
spark
64+
sparkSession
6565
}
6666

6767
def withTempTable(tableNames: String*)(f: => Unit): Unit = {

0 commit comments

Comments
 (0)