Update user manual and add test for backticks

Signed-off-by: Chen Dai <[email protected]>
opensearch-project · Oct 31, 2023 · 1ac46b1 · 1ac46b1
1 parent d36c7e8
commit 1ac46b1
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 0 deletions.
diff --git a/docs/index.md b/docs/index.md
@@ -262,6 +262,20 @@ WITH (
 )
 ```
 
+### Index Job Management
+
+Currently Flint index job ID is same as internal Flint index name in [OpenSearch](./index.md#OpenSearch) section below.
+
+```sql
+RECOVER INDEX JOB <id>
+```
+
+Example:
+
+```sql
+RECOVER INDEX JOB `flint_spark_catalog_default_test_skipping_index`
+```
+
 ## Index Store
 
 ### OpenSearch

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
@@ -48,6 +48,13 @@ class FlintSparkIndexJobSqlITSuite extends FlintSparkSuite with Matchers {
              |""".stripMargin)
         .run(s"RECOVER INDEX JOB $testSkippingIndex")
         .assertIndexData(indexData => indexData should have size 6)
+        .stopStreamingJob()
+        .run(s"""
+                | INSERT INTO $testTable VALUES
+                | (TIMESTAMP '2023-10-01 06:00:00', 'G', 40, 'Vancouver')
+                |""".stripMargin)
+        .run(s"RECOVER INDEX JOB `$testSkippingIndex`") // test backtick name
+        .assertIndexData(indexData => indexData should have size 7)
 
     }
   }