From 4461936a4802c50c944533d5ca238877213d0137 Mon Sep 17 00:00:00 2001 From: DaveTeng0 Date: Tue, 14 Mar 2023 22:23:12 -0700 Subject: [PATCH] HDDS-8163 Use try-with-resources to ensure close rockdb connection in SstFilteringService --- .../apache/hadoop/ozone/om/SstFilteringService.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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 17be6142d86..43effdcc0c3 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";