syntax fix

Signed-off-by: Sean Kao <[email protected]>
opensearch-project · Oct 31, 2024 · 3b22dcf · 3b22dcf
1 parent 559b393
commit 3b22dcf
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/...k-integration/src/test/scala/org/opensearch/flint/spark/FlintSparkIndexFactorySuite.scala b/...k-integration/src/test/scala/org/opensearch/flint/spark/FlintSparkIndexFactorySuite.scala
@@ -14,12 +14,11 @@ import org.apache.spark.FlintSuite
 
 class FlintSparkIndexFactorySuite extends FlintSuite {
 
-  /** Test table, MV name and query */
-  val testTable = "spark_catalog.default.mv_build_test"
-  val testMvName = "spark_catalog.default.mv"
-  val testQuery = s"SELECT * FROM $testTable"
-
   test("create mv should generate source tables if missing in metadata") {
+    val testTable = "spark_catalog.default.mv_build_test"
+    val testMvName = "spark_catalog.default.mv"
+    val testQuery = s"SELECT * FROM $testTable"
+
     val content =
       s""" {
         |    "_meta": {
@@ -31,7 +30,7 @@ class FlintSparkIndexFactorySuite extends FlintSuite {
         |        }
         |      ],
         |      "name": "$testMvName",
-        |      "source": "SELECT age FROM $testTable"
+        |      "source": "$testQuery"
         |    },
         |    "properties": {
         |      "age": {