diff --git a/integ-test/src/test/scala/org/opensearch/flint/core/FlintClientBuilderSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/core/FlintClientBuilderSuite.scala
index ac7fd92ee..f5f1a06df 100644
--- a/integ-test/src/test/scala/org/opensearch/flint/core/FlintClientBuilderSuite.scala
+++ b/integ-test/src/test/scala/org/opensearch/flint/core/FlintClientBuilderSuite.scala
@@ -21,7 +21,8 @@ class FlintClientBuilderSuite extends AnyFlatSpec with OpenSearchSuite with Matc
   }
 
   it should "fail if cannot instantiate metadata log service" in {
-    val options = openSearchOptions + (FlintOptions.CUSTOM_FLINT_METADATA_LOG_SERVICE_CLASS -> "org.dummy.Class")
+    val options =
+      openSearchOptions + (FlintOptions.CUSTOM_FLINT_METADATA_LOG_SERVICE_CLASS -> "org.dummy.Class")
     the[RuntimeException] thrownBy {
       FlintClientBuilder.build(new FlintOptions(options.asJava))
     }
diff --git a/integ-test/src/test/scala/org/opensearch/flint/core/FlintMetadataLogITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/core/FlintMetadataLogITSuite.scala
index bde344d45..b49622f18 100644
--- a/integ-test/src/test/scala/org/opensearch/flint/core/FlintMetadataLogITSuite.scala
+++ b/integ-test/src/test/scala/org/opensearch/flint/core/FlintMetadataLogITSuite.scala
@@ -50,7 +50,8 @@ class FlintMetadataLogITSuite extends OpenSearchTransactionSuite with Matchers {
 
   test("should fail if metadata log index doesn't exists") {
     val options = openSearchOptions + (DATA_SOURCE_NAME.key -> "non-exist-datasource")
-    val flintMetadataLogService = new FlintOpenSearchMetadataLogService(new FlintOptions(options.asJava))
+    val flintMetadataLogService =
+      new FlintOpenSearchMetadataLogService(new FlintOptions(options.asJava))
 
     the[IllegalStateException] thrownBy {
       flintMetadataLogService.startTransaction(testFlintIndex)
@@ -78,14 +79,16 @@ class FlintMetadataLogITSuite extends OpenSearchTransactionSuite with Matchers {
 
   test("should not get index metadata log if not exist") {
     val options = openSearchOptions + (DATA_SOURCE_NAME.key -> "non-exist-datasource")
-    val flintMetadataLogService = new FlintOpenSearchMetadataLogService(new FlintOptions(options.asJava))
+    val flintMetadataLogService =
+      new FlintOpenSearchMetadataLogService(new FlintOptions(options.asJava))
     val metadataLog = flintMetadataLogService.getIndexMetadataLog(testFlintIndex)
     metadataLog.isPresent shouldBe false
   }
 
   test("should initialize index metadata log if forceInit") {
     val options = openSearchOptions + (DATA_SOURCE_NAME.key -> "non-exist-datasource")
-    val flintMetadataLogService = new FlintOpenSearchMetadataLogService(new FlintOptions(options.asJava))
+    val flintMetadataLogService =
+      new FlintOpenSearchMetadataLogService(new FlintOptions(options.asJava))
     val metadataLog = flintMetadataLogService.getIndexMetadataLog(testFlintIndex, true)
     metadataLog.isPresent shouldBe true
   }
diff --git a/integ-test/src/test/scala/org/opensearch/flint/core/FlintTransactionITSuite.scala b/integ-test/src/test/scala/org/opensearch/flint/core/FlintTransactionITSuite.scala
index faff3341c..6da232389 100644
--- a/integ-test/src/test/scala/org/opensearch/flint/core/FlintTransactionITSuite.scala
+++ b/integ-test/src/test/scala/org/opensearch/flint/core/FlintTransactionITSuite.scala
@@ -30,7 +30,8 @@ class FlintTransactionITSuite extends OpenSearchTransactionSuite with Matchers {
   override def beforeAll(): Unit = {
     super.beforeAll()
     val options = openSearchOptions + (DATA_SOURCE_NAME.key -> testDataSourceName)
-    flintMetadataLogService = new FlintOpenSearchMetadataLogService(new FlintOptions(options.asJava))
+    flintMetadataLogService = new FlintOpenSearchMetadataLogService(
+      new FlintOptions(options.asJava))
   }
 
   test("empty metadata log entry content") {