[pulsar] branch master updated: [fix][broker] add return for PersistentMessageExpiryMonitor#findEntryFailed

[penghui]

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 9281bbdb925 [fix][broker] add return for 
PersistentMessageExpiryMonitor#findEntryFailed
9281bbdb925 is described below

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

    [fix][broker] add return for PersistentMessageExpiryMonitor#findEntryFailed
---
 .../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 9b1cd75282a..4335762a21b 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
@@ -215,6 +215,7 @@ public class PersistentMessageExpiryMonitor implements 
FindEntryCallback {
             } else {
                 findEntryComplete(failedReadPosition.get(), ctx);
             }
+            return;
         }
         expirationCheckInProgress = FALSE;
         updateRates();