You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2026/04/21 22:31:13 UTC
(pulsar) branch master updated: [fix][broker] Lower log level of DrainingHashesTracker not-found entry to DEBUG (#25558)
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 <vi...@gmail.com>
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)