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 index 4e91ae27c1..497f6e0213 100644 --- 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,7 +87,6 @@ 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, @@ -95,7 +94,7 @@ public class IndexQuerySpecTest extends AsyncQueryExecutorServiceSpec { 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 index 67c89c791c..738b7338b5 100644 --- 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 index 63943d17f3..72c83c59fa 100644 --- 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=" } }