This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 0c6abe0f3233a8ca68d26e53c01ebe5f7b2931e2 Author: Lari Hotari <[email protected]> AuthorDate: Tue Oct 1 22:54:32 2024 +0300 [fix][broker] Cancel possible pending replay read in cancelPendingRead (#23384) (cherry picked from commit d2c91b1e1a8fc2fb233eb2856ddb6f53511ba201) --- .../service/persistent/PersistentDispatcherMultipleConsumers.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java index 2983639c76a..07178cd9612 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java @@ -600,8 +600,9 @@ public class PersistentDispatcherMultipleConsumers extends AbstractDispatcherMul @Override protected void cancelPendingRead() { - if (havePendingRead && cursor.cancelPendingReadRequest()) { + if ((havePendingRead || havePendingReplayRead) && cursor.cancelPendingReadRequest()) { havePendingRead = false; + havePendingReplayRead = false; } }
