YBK-161: Fixed a few small leaks

YahooArchive · Oct 19, 2017 · 241ac16 · 241ac16
1 parent 74feb75
commit 241ac16
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...er-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LedgerMetadataIndex.java b/...er-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LedgerMetadataIndex.java
@@ -217,6 +217,7 @@ public void flush() throws IOException {
         }
 
         ledgersDb.sync();
+        key.recycle();
     }
 
     public void removeDeletedLedgers() throws IOException {
@@ -227,13 +228,15 @@ public void removeDeletedLedgers() throws IOException {
             long ledgerId = pendingDeletedLedgers.poll();
             key.set(ledgerId);
             ledgersDb.delete(key.array);
+            deletedLedgers++;
         }
 
         if (log.isDebugEnabled()) {
-            log.debug("Persisting deletes of ledgers", deletedLedgers);
+            log.debug("Persisting deletes of ledgers {}", deletedLedgers);
         }
 
         ledgersDb.sync();
+        key.recycle();
     }
 
     private static final Logger log = LoggerFactory.getLogger(LedgerMetadataIndex.class);