Fix recover index IT

Signed-off-by: Chen Dai <[email protected]>
opensearch-project · Nov 9, 2023 · c73906a · c73906a
1 parent 6e511c1
commit c73906a
Showing 1 changed file with 3 additions and 1 deletion.
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
@@ -67,9 +67,10 @@ class FlintSparkIndexJobSqlITSuite extends FlintSparkSuite with Matchers {
       assertion
         .run { checkpointDir =>
           s""" CREATE INDEX $testIndex ON $testTable
-             | (time, name)
+             | (timestamp, name)
              | WITH (
              |   auto_refresh = true,
+             |   id_expression = 'timestamp',
              |   checkpoint_location = '${checkpointDir.getAbsolutePath}'
              | )
              |""".stripMargin
@@ -94,6 +95,7 @@ class FlintSparkIndexJobSqlITSuite extends FlintSparkSuite with Matchers {
              | $testMvQuery
              | WITH (
              |   auto_refresh = true,
+             |   id_expression = 'name',
              |   checkpoint_location = '${checkpointDir.getAbsolutePath}'
              | )
              |""".stripMargin