Remove skipping index name

Signed-off-by: Chen Dai <[email protected]>
opensearch-project · Oct 20, 2023 · 4a54dd5 · 4a54dd5
1 parent 01a8f34
commit 4a54dd5
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
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
@@ -60,7 +60,7 @@ case class FlintSparkSkippingIndex(
     val schemaJson = generateSchemaJSON(fieldTypes)
 
     metadataBuilder(this)
-      .name(name())
+      .name("") // skipping index is unique per table without name
       .source(tableName)
       .indexedColumns(indexColumnMaps)
       .schema(schemaJson)

diff --git a/...ion/src/test/scala/org/opensearch/flint/spark/skipping/FlintSparkSkippingIndexSuite.scala b/...ion/src/test/scala/org/opensearch/flint/spark/skipping/FlintSparkSkippingIndexSuite.scala
@@ -40,7 +40,7 @@ class FlintSparkSkippingIndexSuite extends FlintSuite {
 
     val metadata = index.metadata()
     metadata.kind shouldBe SKIPPING_INDEX_TYPE
-    metadata.name shouldBe index.name()
+    metadata.name shouldBe ""
     metadata.source shouldBe testTable
     metadata.indexedColumns shouldBe Array(
       Map(

diff --git a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkIndexJobSqlITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkIndexJobSqlITSuite.scala
@@ -45,21 +45,21 @@ class FlintSparkIndexJobSqlITSuite extends FlintSparkSuite {
     startSkippingIndexJob()
     checkAnswer(
       sql("SHOW INDEX JOBS"),
-      Seq(Row(testSkippingIndex, testSkippingIndex, testTable, "{}")))
+      Seq(Row(testSkippingIndex, "", testTable, "{}")))
 
     startCoveringIndexJob()
     checkAnswer(
       sql("SHOW INDEX JOBS"),
       Seq(
-        Row(testSkippingIndex, testSkippingIndex, testTable, "{}"),
+        Row(testSkippingIndex, "", testTable, "{}"),
         Row(testCoveringIndex, testIndex, testTable, "{}")))
 
     withTempDir { checkpointDir =>
       startMaterializedViewIndexJob(checkpointDir)
       checkAnswer(
         sql("SHOW INDEX JOBS"),
         Seq(
-          Row(testSkippingIndex, testSkippingIndex, testTable, "{}"),
+          Row(testSkippingIndex, "", testTable, "{}"),
           Row(testCoveringIndex, testIndex, testTable, "{}"),
           Row(testMvIndex, testMv, testMvQuery, "{}")))
     }

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
@@ -54,7 +54,7 @@ class FlintSparkSkippingIndexITSuite extends FlintSparkSuite {
     index shouldBe defined
     index.get.metadata().getContent should matchJson(s"""{
         |   "_meta": {
-        |     "name": "flint_spark_catalog_default_test_skipping_index",
+        |     "name": "",
         |     "version": "${current()}",
         |     "kind": "skipping",
         |     "indexedColumns": [
@@ -452,7 +452,7 @@ class FlintSparkSkippingIndexITSuite extends FlintSparkSuite {
     index.get.metadata().getContent should matchJson(
       s"""{
          |   "_meta": {
-         |     "name": "flint_spark_catalog_default_data_type_table_skipping_index",
+         |     "name": "",
          |     "version": "${current()}",
          |     "kind": "skipping",
          |     "indexedColumns": [