[pulsar] branch master updated: [fix][broker] Release the entry in getEarliestMessagePublishTimeOfPos (#16386)

[pe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 1f470a0b333 [fix][broker] Release the entry in getEarliestMessagePublishTimeOfPos (#16386)
1f470a0b333 is described below

commit 1f470a0b33356eb36ae23c674cfcb4a33cc76205
Author: Jiwei Guo <te...@apache.org>
AuthorDate: Wed Jul 6 08:33:29 2022 +0800

    [fix][broker] Release the entry in getEarliestMessagePublishTimeOfPos (#16386)
---
 .../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 867ef683691..ee1da48bbd4 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
@@ -1203,6 +1203,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();
                 }
             }