Fix broken IT

Signed-off-by: Chen Dai <[email protected]>

flint-spark-integration/src/main/scala/org/opensearch/flint/spark/FlintSpark.scala

@@ -204,13 +204,13 @@ class FlintSpark(val spark: SparkSession) extends FlintSparkTransactionSupport w
    */
   def updateIndex(index: FlintSparkIndex): Option[String] = {
     val indexName = index.name()
-    withTransaction[Option[String]](indexName, s"Update Flint index $indexName") { tx =>
-      validateUpdateAllowed(
-        describeIndex(indexName)
-          .getOrElse(throw new IllegalStateException(s"Index $indexName doesn't exist"))
-          .options,
-        index.options)
+    validateUpdateAllowed(
+      describeIndex(indexName)
+        .getOrElse(throw new IllegalStateException(s"Index $indexName doesn't exist"))
+        .options,
+      index.options)
 
+    withTransaction[Option[String]](indexName, s"Update Flint index $indexName") { tx =>
       // Relies on validation to forbid auto-to-auto and manual-to-manual updates
       index.options.autoRefresh() match {
         case true => updateIndexManualToAuto(index, tx)

integ-test/src/test/scala/org/opensearch/flint/spark/FlintSparkTransactionITSuite.scala

@@ -195,7 +195,8 @@ class FlintSparkTransactionITSuite extends OpenSearchTransactionSuite with Match
         .onTable(testTable)
         .addValueSet("name")
         .create()
-    } should have message s"Flint index $testFlintIndex already exists"
+    } should have message
+      s"Failed to execute index operation [Create Flint index $testFlintIndex with ignoreIfExists false] caused by: Flint index $testFlintIndex already exists"
   }
 
   test("should clean up metadata log entry if index data has been deleted") {