diff --git a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkCoveringIndexSqlITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkCoveringIndexSqlITSuite.scala index b3e2ef063..27419b616 100644 --- a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkCoveringIndexSqlITSuite.scala +++ b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkCoveringIndexSqlITSuite.scala @@ -130,8 +130,7 @@ class FlintSparkCoveringIndexSqlITSuite extends FlintSparkSuite { | (name, age) | WITH (auto_refresh = true) | """.stripMargin) - } should have message - "Checkpoint location is mandatory for incremental refresh if spark.flint.index.checkpoint.mandatory enabled" + } } finally { setFlintSparkConf(CHECKPOINT_MANDATORY, "false") } diff --git a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkSkippingIndexSqlITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkSkippingIndexSqlITSuite.scala index 7b30349ba..21de15de7 100644 --- a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkSkippingIndexSqlITSuite.scala +++ b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkSkippingIndexSqlITSuite.scala @@ -119,8 +119,7 @@ class FlintSparkSkippingIndexSqlITSuite extends FlintSparkSuite { | ( year PARTITION ) | WITH (auto_refresh = true) | """.stripMargin) - } should have message - "Checkpoint location is mandatory for incremental refresh if spark.flint.index.checkpoint.mandatory enabled" + } } finally { setFlintSparkConf(CHECKPOINT_MANDATORY, "false") }