diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LedgerMetadataIndex.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LedgerMetadataIndex.java index 0d841de22f1..26345b07b97 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LedgerMetadataIndex.java +++ b/bookkeeper-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);