Skip to content

Commit

Permalink
Revert unrelated change
Browse files Browse the repository at this point in the history
Signed-off-by: Tomoyuki Morita <[email protected]>
  • Loading branch information
ykmr1224 committed Aug 16, 2024
1 parent 0a71be4 commit 8576224
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -46,16 +46,15 @@ class FlintMetadataLogITSuite extends OpenSearchTransactionSuite with Matchers {

test("should build metadata log service") {
val customOptions =
openSearchOptions + (FlintOptions.CUSTOM_FLINT_METADATA_LOG_SERVICE_CLASS -> "org.opensearch.flint.core.TestMetadataLogService")
openSearchOptions + (CUSTOM_FLINT_METADATA_LOG_SERVICE_CLASS.key -> "org.opensearch.flint.core.TestMetadataLogService")
val customFlintOptions = new FlintOptions(customOptions.asJava)
val customFlintMetadataLogService =
FlintMetadataLogServiceBuilder.build(customFlintOptions, sparkConf)
customFlintMetadataLogService shouldBe a[TestMetadataLogService]
}

test("should fail to build metadata log service if class name doesn't exist") {
val options =
openSearchOptions + (FlintOptions.CUSTOM_FLINT_METADATA_LOG_SERVICE_CLASS -> "dummy")
val options = openSearchOptions + (CUSTOM_FLINT_METADATA_LOG_SERVICE_CLASS.key -> "dummy")
val flintOptions = new FlintOptions(options.asJava)
the[RuntimeException] thrownBy {
FlintMetadataLogServiceBuilder.build(flintOptions, sparkConf)
Expand Down

0 comments on commit 8576224

Please sign in to comment.