From 667f5c22625bae1f905c26962f9d5fce892358c6 Mon Sep 17 00:00:00 2001 From: Sean Kao Date: Wed, 12 Jun 2024 13:27:54 -0700 Subject: [PATCH] scalafmtAll Signed-off-by: Sean Kao --- .../opensearch/flint/core/FlintClientBuilderSuite.scala | 3 ++- .../opensearch/flint/core/FlintMetadataLogITSuite.scala | 9 ++++++--- .../opensearch/flint/core/FlintTransactionITSuite.scala | 3 ++- 3 files changed, 10 insertions(+), 5 deletions(-) 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") {