This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.10 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 9ee69c05d5cbdc0aa6307d15b180ed62dfc8ec03 Author: Jiwei Guo <[email protected]> AuthorDate: Wed Jul 6 08:33:29 2022 +0800 [fix][broker] Release the entry in getEarliestMessagePublishTimeOfPos (#16386) (cherry picked from commit 1f470a0b33356eb36ae23c674cfcb4a33cc76205) --- .../main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java index d1267fed27a..973a5253a9b 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java @@ -1197,6 +1197,8 @@ public class ManagedLedgerImpl implements ManagedLedger, CreateCallback { } catch (IOException e) { log.error("Error deserializing message for message position {}", nextPos, e); future.completeExceptionally(e); + } finally { + entry.release(); } }
