update

wayneguow · Jul 26, 2024 · 2f54c99 · 2f54c99
1 parent 901c688
commit 2f54c99
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/StringFunctionsSuite.scala
@@ -426,11 +426,13 @@ class StringFunctionsSuite extends QueryTest with SharedSparkSession {
     )
 
     val testTable = "test_substring_index"
-    withTable(testTable) {
-      sql(s"CREATE TABLE ${testTable} (num int) USING parquet")
-      sql(s"INSERT INTO ${testTable} VALUES (1), (2), (3), (NULL)")
-      val query = s"SELECT num, SUBSTRING_INDEX('a_a_a', '_', num) as sub_str FROM ${testTable}"
-      checkAnswer(sql(query), Seq(Row(1, "a"), Row(2, "a_a"), Row(3, "a_a_a"), Row(null, null)))
+    withTempPath { path =>
+      withTable(testTable) {
+        sql(s"CREATE TABLE $testTable (num int) USING parquet LOCATION '${path.toURI.toString}'")
+        sql(s"INSERT INTO $testTable VALUES (1), (2), (3), (NULL)")
+        val query = s"SELECT num, SUBSTRING_INDEX('a_a_a', '_', num) as sub_str FROM $testTable"
+        checkAnswer(sql(query), Seq(Row(1, "a"), Row(2, "a_a"), Row(3, "a_a_a"), Row(null, null)))
+      }
     }
   }