spec test vacuum

Signed-off-by: Sean Kao <[email protected]>
opensearch-project · Mar 19, 2024 · 2a08946 · 2a08946
1 parent 3b817c4
commit 2a08946
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 4 deletions.
diff --git a/spark/src/test/java/org/opensearch/sql/spark/asyncquery/IndexQuerySpecTest.java b/spark/src/test/java/org/opensearch/sql/spark/asyncquery/IndexQuerySpecTest.java
@@ -87,15 +87,14 @@ public class IndexQuerySpecTest extends AsyncQueryExecutorServiceSpec {
           FlintIndexType.MATERIALIZED_VIEW,
           "flint_mys3_default_http_logs_metrics")
           .latestId("ZmxpbnRfbXlzM19kZWZhdWx0X2h0dHBfbG9nc19tZXRyaWNz");
-
   public final FlintDatasetMock SPECIAL_CHARACTERS =
       new FlintDatasetMock(
               "DROP SKIPPING INDEX ON mys3.default." + specialName,
               REFRESH_SCI,
               FlintIndexType.SKIPPING,
               "flint_mys3_default_" + encodedName + "_skipping_index")
           .isSpecialCharacter(true)
-          .latestId("specialcharacterindexid");
+          .latestId("ZmxpbnRfbXlzM19kZWZhdWx0X3Rlc3QlMjAlMmMlM2ElMjIlMmIlMmYlNWMlN2MlM2YlMjMlM2UlM2Nfc2tpcHBpbmdfaW5kZXg=");
 
   public final String CREATE_SI_AUTO =
       "CREATE SKIPPING INDEX ON mys3.default.http_logs"

diff --git a/spark/src/test/java/org/opensearch/sql/spark/asyncquery/IndexQuerySpecVacuumTest.java b/spark/src/test/java/org/opensearch/sql/spark/asyncquery/IndexQuerySpecVacuumTest.java
@@ -54,7 +54,12 @@ public class IndexQuerySpecVacuumTest extends AsyncQueryExecutorServiceSpec {
           mockDataset(
               "VACUUM MATERIALIZED VIEW mys3.default.http_logs_metrics",
               MATERIALIZED_VIEW,
-              "flint_mys3_default_http_logs_metrics"));
+              "flint_mys3_default_http_logs_metrics"),
+          mockDataset(
+              "VACUUM SKIPPING INDEX ON mys3.default.`test ,:\"+/\\|?#><`",
+              SKIPPING,
+              "flint_mys3_default_test%20%2c%3a%22%2b%2f%5c%7c%3f%23%3e%3c_skipping_index")
+              .isSpecialCharacter(true));
 
   @Test
   public void shouldVacuumIndexInRefreshingState() {

diff --git a/spark/src/test/resources/flint-index-mappings/0.1.1/flint_special_character_index.json b/spark/src/test/resources/flint-index-mappings/0.1.1/flint_special_character_index.json
@@ -18,6 +18,6 @@
         "SERVERLESS_EMR_JOB_ID": "00fdmvv9hp8u0o0q"
       }
     },
-    "latestId": "specialcharacterindexid"
+    "latestId": "ZmxpbnRfbXlzM19kZWZhdWx0X3Rlc3QlMjAlMmMlM2ElMjIlMmIlMmYlNWMlN2MlM2YlMjMlM2UlM2Nfc2tpcHBpbmdfaW5kZXg="
   }
 }