Change IT for options with default

Signed-off-by: Chen Dai <[email protected]>
opensearch-project · Oct 6, 2023 · 1df95c9 · 1df95c9
1 parent 274b5a5
commit 1df95c9
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/...egration/src/main/scala/org/opensearch/flint/spark/covering/FlintSparkCoveringIndex.scala b/...egration/src/main/scala/org/opensearch/flint/spark/covering/FlintSparkCoveringIndex.scala
@@ -74,7 +74,7 @@ case class FlintSparkCoveringIndex(
   }
 
   private def getIndexOptions: String = {
-    Serialization.write(options.options)
+    Serialization.write(options.optionsWithDefault)
   }
 
   private def getIndexProperties: String = {

diff --git a/...egration/src/main/scala/org/opensearch/flint/spark/skipping/FlintSparkSkippingIndex.scala b/...egration/src/main/scala/org/opensearch/flint/spark/skipping/FlintSparkSkippingIndex.scala
@@ -87,7 +87,7 @@ class FlintSparkSkippingIndex(
   }
 
   private def getIndexOptions: String = {
-    Serialization.write(options.options)
+    Serialization.write(options.optionsWithDefault)
   }
 
   private def getIndexProperties: String = {

diff --git a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkCoveringIndexITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkCoveringIndexITSuite.scala
@@ -57,7 +57,7 @@ class FlintSparkCoveringIndexITSuite extends FlintSparkSuite {
          |        "columnType": "int"
          |     }],
          |     "source": "spark_catalog.default.ci_test",
-         |     "options": {},
+         |     "options": { "auto_refresh": "false" },
          |     "properties": {}
          |   },
          |   "properties": {

diff --git a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkSkippingIndexITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkSkippingIndexITSuite.scala
@@ -79,7 +79,7 @@ class FlintSparkSkippingIndexITSuite extends FlintSparkSuite {
         |        "columnType": "int"
         |     }],
         |     "source": "spark_catalog.default.test",
-        |     "options": {},
+        |     "options": { "auto_refresh": "false" },
         |     "properties": {}
         |   },
         |   "properties": {
@@ -105,7 +105,7 @@ class FlintSparkSkippingIndexITSuite extends FlintSparkSuite {
         | }
         |""".stripMargin)
 
-    index.get.options shouldBe FlintSparkIndexOptions.empty
+    index.get.options shouldBe FlintSparkIndexOptions(Map("auto_refresh" -> "false"))
   }
 
   test("create skipping index with index options successfully") {
@@ -522,7 +522,7 @@ class FlintSparkSkippingIndexITSuite extends FlintSparkSuite {
          |        "columnType": "struct<subfield1:string,subfield2:int>"
          |     }],
          |     "source": "$testTable",
-         |     "options": {},
+         |     "options": { "auto_refresh": "false" },
          |     "properties": {}
          |   },
          |   "properties": {