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

[xi...@apache.org]

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

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


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new a5a3a10fee3 [fix][broker] add return for PersistentMessageExpiryMonitor#findEntryFailed
a5a3a10fee3 is described below

commit a5a3a10fee3ca4f89ef02047679bf89ac051ac66
Author: HuangZeGui <hz...@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 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();