This is an automated email from the ASF dual-hosted git repository.
lhotari 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 423a74698e1 [fix][broker] Lower log level of DrainingHashesTracker
not-found entry to DEBUG (#25558)
423a74698e1 is described below
commit 423a74698e1b44652425f030788ac54484052f85
Author: Vishal Kumar Singh <[email protected]>
AuthorDate: Wed Apr 22 04:01:05 2026 +0530
[fix][broker] Lower log level of DrainingHashesTracker not-found entry to
DEBUG (#25558)
---
.../org/apache/pulsar/broker/service/DrainingHashesTracker.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java
index f5bbd42936f..9edc88f88cf 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java
@@ -188,7 +188,11 @@ public class DrainingHashesTracker {
int hash = hashIterator.nextInt();
DrainingHashEntry entry = getEntry(hash);
if (entry == null) {
- log.warn()
+ // Not-found entries are expected as a benign race
between the draining-hash
+ // stats read path and the draining-hash removal path
(fixed in #23854 to
+ // avoid deadlocks). Logging at WARN was noisy; DEBUG
keeps the signal for
+ // troubleshooting without polluting broker logs.
+ log.debug()
.attr("dispatcher", dispatcherName)
.attr("hash", hash)
.attr("consumer", consumer)
