From 959c8a498a5b727246f9518b79817c5fc77ab499 Mon Sep 17 00:00:00 2001 From: Takeshi Yamamuro Date: Sat, 25 Apr 2020 11:51:08 +0900 Subject: [PATCH] Fix --- .../spark/sql/SparkSessionBuilderSuite.scala | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionBuilderSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionBuilderSuite.scala index 632856d207dc..46fb2ff4c53c 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionBuilderSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/SparkSessionBuilderSuite.scala @@ -157,28 +157,28 @@ class SparkSessionBuilderSuite extends SparkFunSuite with BeforeAndAfterEach { "spark context conf values in SessionState") { val session = SparkSession.builder() .master("local") - .config(GLOBAL_TEMP_DATABASE.key, value = "globalTempDB-SPARK-31234") + .config(GLOBAL_TEMP_DATABASE.key, value = "globaltempdb-spark-31234") .config("spark.app.name", "test-app-SPARK-31234") .getOrCreate() assert(session.sessionState.conf.getConfString("spark.app.name") === "test-app-SPARK-31234") - assert(session.sessionState.conf.getConf(GLOBAL_TEMP_DATABASE) === "globalTempDB-SPARK-31234") + assert(session.sessionState.conf.getConf(GLOBAL_TEMP_DATABASE) === "globaltempdb-spark-31234") session.sql("RESET") assert(session.sessionState.conf.getConfString("spark.app.name") === "test-app-SPARK-31234") - assert(session.sessionState.conf.getConf(GLOBAL_TEMP_DATABASE) === "globalTempDB-SPARK-31234") + assert(session.sessionState.conf.getConf(GLOBAL_TEMP_DATABASE) === "globaltempdb-spark-31234") } test("SPARK-31532: should not propagate static sql configs to the existing" + " active/default SparkSession") { val session = SparkSession.builder() .master("local") - .config(GLOBAL_TEMP_DATABASE.key, value = "globalTempDB-SPARK-31532") + .config(GLOBAL_TEMP_DATABASE.key, value = "globaltempdb-spark-31532") .config("spark.app.name", "test-app-SPARK-31532") .getOrCreate() // do not propagate static sql configs to the existing active session val session1 = SparkSession .builder() - .config(GLOBAL_TEMP_DATABASE.key, "globalTempDB-SPARK-31532-1") + .config(GLOBAL_TEMP_DATABASE.key, "globaltempdb-spark-31532-1") .getOrCreate() assert(session.conf.get(GLOBAL_TEMP_DATABASE) === "globaltempdb-spark-31532") assert(session1.conf.get(GLOBAL_TEMP_DATABASE) === "globaltempdb-spark-31532") @@ -188,7 +188,7 @@ class SparkSessionBuilderSuite extends SparkFunSuite with BeforeAndAfterEach { val session2 = SparkSession .builder() .config(WAREHOUSE_PATH.key, "SPARK-31532-db") - .config(GLOBAL_TEMP_DATABASE.key, value = "globalTempDB-SPARK-31532-2") + .config(GLOBAL_TEMP_DATABASE.key, value = "globaltempdb-spark-31532-2") .getOrCreate() assert(!session.conf.get(WAREHOUSE_PATH).contains("SPARK-31532-db")) @@ -207,7 +207,7 @@ class SparkSessionBuilderSuite extends SparkFunSuite with BeforeAndAfterEach { // propagate static sql configs if no existing session val session = SparkSession .builder() - .config(GLOBAL_TEMP_DATABASE.key, "globalTempDB-SPARK-31532-2") + .config(GLOBAL_TEMP_DATABASE.key, "globaltempdb-spark-31532-2") .config(WAREHOUSE_PATH.key, "SPARK-31532-db-2") .getOrCreate() assert(session.conf.get("spark.app.name") === "test-app-SPARK-31532-2")