diff --git a/beekeeper-metadata-cleanup/src/main/java/com/expediagroup/beekeeper/metadata/cleanup/context/CommonBeans.java b/beekeeper-metadata-cleanup/src/main/java/com/expediagroup/beekeeper/metadata/cleanup/context/CommonBeans.java index 6526f248..36509532 100644 --- a/beekeeper-metadata-cleanup/src/main/java/com/expediagroup/beekeeper/metadata/cleanup/context/CommonBeans.java +++ b/beekeeper-metadata-cleanup/src/main/java/com/expediagroup/beekeeper/metadata/cleanup/context/CommonBeans.java @@ -81,8 +81,7 @@ public CloseableMetaStoreClientFactory metaStoreClientFactory() { @Bean Supplier metaStoreClientSupplier( - CloseableMetaStoreClientFactory metaStoreClientFactory, - HiveConf hiveConf) { + CloseableMetaStoreClientFactory metaStoreClientFactory, HiveConf hiveConf) { String name = "beekeeper-metadata-cleanup"; return new HiveMetaStoreClientSupplier(metaStoreClientFactory, hiveConf, name); } @@ -103,8 +102,7 @@ public DeletedMetadataReporter deletedMetadataReporter( @Bean(name = "hiveTableCleaner") MetadataCleaner metadataCleaner( - DeletedMetadataReporter deletedMetadataReporter, - IcebergValidator icebergValidator) { + DeletedMetadataReporter deletedMetadataReporter, IcebergValidator icebergValidator) { return new HiveMetadataCleaner(deletedMetadataReporter, icebergValidator); } @@ -141,8 +139,7 @@ public S3Client s3Client(AmazonS3 amazonS3, @Value("${properties.dry-run-enabled @Bean(name = "s3PathCleaner") PathCleaner pathCleaner( S3Client s3Client, - BytesDeletedReporter bytesDeletedReporter, - IcebergValidator icebergValidator) { + BytesDeletedReporter bytesDeletedReporter, IcebergValidator icebergValidator) { return new S3PathCleaner(s3Client, new S3SentinelFilesCleaner(s3Client), bytesDeletedReporter, icebergValidator); } diff --git a/beekeeper-metadata-cleanup/src/test/java/com/expediagroup/beekeeper/metadata/cleanup/context/CommonBeansTest.java b/beekeeper-metadata-cleanup/src/test/java/com/expediagroup/beekeeper/metadata/cleanup/context/CommonBeansTest.java index 83dbc389..e5659ea9 100644 --- a/beekeeper-metadata-cleanup/src/test/java/com/expediagroup/beekeeper/metadata/cleanup/context/CommonBeansTest.java +++ b/beekeeper-metadata-cleanup/src/test/java/com/expediagroup/beekeeper/metadata/cleanup/context/CommonBeansTest.java @@ -161,8 +161,7 @@ void verifyS3pathCleaner() { @Test public void verifyExpiredMetadataHandler() { ExpiredMetadataHandler expiredMetadataHandler = commonBeans.expiredMetadataHandler(hiveClientFactory, - metadataRepository, - metadataCleaner, pathCleaner); + metadataRepository, metadataCleaner, pathCleaner); assertThat(expiredMetadataHandler).isInstanceOf(ExpiredMetadataHandler.class); } diff --git a/beekeeper-scheduler-apiary/src/test/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGeneratorTest.java b/beekeeper-scheduler-apiary/src/test/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGeneratorTest.java index 189ab938..5041c910 100644 --- a/beekeeper-scheduler-apiary/src/test/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGeneratorTest.java +++ b/beekeeper-scheduler-apiary/src/test/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGeneratorTest.java @@ -1,5 +1,5 @@ /** - * Copyright (C) 2019-2022 Expedia, Inc. + * Copyright (C) 2019-2024 Expedia, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -33,7 +33,6 @@ import java.util.List; import java.util.Map; - import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; diff --git a/beekeeper-scheduler-apiary/src/test/java/com/expediagroup/beekeeper/scheduler/apiary/service/SchedulerApiaryTest.java b/beekeeper-scheduler-apiary/src/test/java/com/expediagroup/beekeeper/scheduler/apiary/service/SchedulerApiaryTest.java index 7551d627..045d1827 100644 --- a/beekeeper-scheduler-apiary/src/test/java/com/expediagroup/beekeeper/scheduler/apiary/service/SchedulerApiaryTest.java +++ b/beekeeper-scheduler-apiary/src/test/java/com/expediagroup/beekeeper/scheduler/apiary/service/SchedulerApiaryTest.java @@ -171,7 +171,7 @@ public void icebergValidatorThrowsException() { verify(icebergValidator).throwExceptionIfIceberg(databaseName, tableName); verifyNoInteractions(pathSchedulerService); verifyNoInteractions(tableSchedulerService); - verify(beekeeperEventReader, times(2)).delete(event.get()); + verify(beekeeperEventReader, times(2)).delete(event.get()); // We need to fix this, we are deleting twice, not sure why } @Test