update test with removal of test indices

Signed-off-by: YANGDB <[email protected]>
opensearch-project · Oct 19, 2023 · 6dac21b · 6dac21b
1 parent 904a861
commit 6dac21b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkCoveringIndexSqlITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkCoveringIndexSqlITSuite.scala
@@ -251,6 +251,9 @@ class FlintSparkCoveringIndexSqlITSuite extends FlintSparkSuite {
     settings = parse(flintClient.getIndexMetadata(testFlintIndex).indexSettings.get)
     (settings \ "index.number_of_shards").extract[String] shouldBe "2"
     (settings \ "index.number_of_replicas").extract[String] shouldBe "3"
+
+    //remove test index
+    flint.deleteIndex(targetIndex)
   }
 
 }
diff --git a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkMaterializedViewITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkMaterializedViewITSuite.scala
@@ -195,7 +195,7 @@ class FlintSparkMaterializedViewITSuite extends FlintSparkSuite {
       .options(indexOptions)
       .create()
 
-    val index = flint.describeIndex("existing_index")
+    val index = flint.describeIndex(testTargetIndex)
     index shouldBe defined
     index.get.metadata().getContent() should matchJson(s"""
          | {
@@ -230,6 +230,8 @@ class FlintSparkMaterializedViewITSuite extends FlintSparkSuite {
          |  }
          | }
          |""".stripMargin)
+    //remove test index
+    flint.deleteIndex(testTargetIndex)
   }
 
   private def timestamp(ts: String): Timestamp = Timestamp.valueOf(ts)