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") {