From 1c3078c2f495054e336b022bb476861d00dc4467 Mon Sep 17 00:00:00 2001 From: Chen Dai Date: Mon, 3 Jun 2024 15:01:11 -0700 Subject: [PATCH] Fix broken IT Signed-off-by: Chen Dai --- .../opensearch/flint/spark/FlintSparkTransactionITSuite.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkTransactionITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkTransactionITSuite.scala index fbed33c81..3edc13e4d 100644 --- a/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkTransactionITSuite.scala +++ b/integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkTransactionITSuite.scala @@ -187,7 +187,7 @@ class FlintSparkTransactionITSuite extends OpenSearchTransactionSuite with Match the[IllegalStateException] thrownBy { flint.vacuumIndex(testFlintIndex) } should have message - s"Failed to execute index operation [Vacuum Flint index $testFlintIndex] caused by: Index state [active] doesn't satisfy precondition" + s"Failed to execute index operation [Vacuum Flint index] caused by: Index state [active] doesn't satisfy precondition" } test("should not recreate index if index data still exists") { @@ -209,7 +209,7 @@ class FlintSparkTransactionITSuite extends OpenSearchTransactionSuite with Match .addValueSet("name") .create() } should have message - s"Failed to execute index operation [Create Flint index $testFlintIndex with ignoreIfExists false] caused by: Flint index $testFlintIndex already exists" + s"Failed to execute index operation [Create Flint index with ignoreIfExists false] caused by: Flint index $testFlintIndex already exists" } test("should clean up metadata log entry if index data has been deleted") {