[pulsar] 03/03: [fix][broker] add return for PersistentMessageExpiryMonitor#findEntryFailed

[bogong]

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

bogong pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 85e65aa93d9ef03848fec7f7bb2536d43aec4565
Author: HuangZeGui <hzgui1...@126.com>
AuthorDate: Mon Oct 10 17:33:14 2022 +0800

    [fix][broker] add return for PersistentMessageExpiryMonitor#findEntryFailed
    
    (cherry picked from commit 9281bbdb92531e06d0baa8e05250928c9d530440)
---
 .../pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java
index 32cff81a64f..911e2a4bebf 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java
@@ -214,6 +214,7 @@ public class PersistentMessageExpiryMonitor implements 
FindEntryCallback {
             } else {
                 findEntryComplete(failedReadPosition.get(), ctx);
             }
+            return;
         }
         expirationCheckInProgress = FALSE;
         updateRates();