diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/SstFilteringService.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/SstFilteringService.java index 17be6142d868..43effdcc0c3a 100644 --- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/SstFilteringService.java +++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/SstFilteringService.java @@ -143,12 +143,12 @@ public BackgroundTaskResult call() throws Exception { String dbName = OM_DB_NAME + snapshotInfo.getCheckpointDirName(); - RDBStore rdbStore = (RDBStore) OmMetadataManagerImpl + try (RDBStore rdbStore = (RDBStore) OmMetadataManagerImpl .loadDB(ozoneManager.getConfiguration(), new File(snapshotDir), - dbName, true); - RocksDatabase db = rdbStore.getDb(); - db.deleteFilesNotMatchingPrefix(prefixPairs, filterFunction); - rdbStore.close(); + dbName, true)) { + RocksDatabase db = rdbStore.getDb(); + db.deleteFilesNotMatchingPrefix(prefixPairs, filterFunction); + } // mark the snapshot as filtered by writing to the file String content = snapshotInfo.getSnapshotID() + "\n";