diff --git a/docs/index.md b/docs/index.md index 05a38dbeb..65dfa9203 100644 --- 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 +``` + +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 index b32bb9f5f..2aa662e89 100644 --- 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) } }