This is an automated email from the ASF dual-hosted git repository. yong pushed a commit to branch branch-4.15 in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
commit f92171f10962531103094a84b65da2e57b137475 Author: wenbingshen <[email protected]> AuthorDate: Fri Feb 10 17:26:34 2023 +0800 recycle LongPairWrapper (#3728) (cherry picked from commit cec8267682202dfb77342db4366fef07ad7632d6) --- .../bookkeeper/bookie/storage/ldb/LocationsIndexRebuildOp.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LocationsIndexRebuildOp.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LocationsIndexRebuildOp.java index e15457ca8e..a3d4df0181 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LocationsIndexRebuildOp.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/LocationsIndexRebuildOp.java @@ -105,7 +105,13 @@ public class LocationsIndexRebuildOp { // Update the ledger index page LongPairWrapper key = LongPairWrapper.get(ledgerId, entryId); LongWrapper value = LongWrapper.get(location); - batch.get().put(key.array, value.array); + + try { + batch.get().put(key.array, value.array); + } finally { + key.recycle(); + value.recycle(); + } if (count.incrementAndGet() > BATCH_COMMIT_SIZE) { batch.get().flush();
