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:38:16 UTC
(pulsar) branch branch-4.1 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 branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new c1548fe4ae9 [fix][broker] Lower log level of DrainingHashesTracker not-found entry to DEBUG (#25558)
c1548fe4ae9 is described below
commit c1548fe4ae9d7fb64b7c07d97f809e19b92e7193
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)
(cherry picked from commit 423a74698e1b44652425f030788ac54484052f85)
---
.../java/org/apache/pulsar/broker/service/DrainingHashesTracker.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 51c45817368..8570e2f4d36 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
@@ -185,8 +185,8 @@ public class DrainingHashesTracker {
int hash = hashIterator.nextInt();
DrainingHashEntry entry = getEntry(hash);
if (entry == null) {
- log.warn("[{}] Draining hash {} not found in the tracker for consumer {}", dispatcherName, hash,
- consumer);
+ log.debug("[{}] Draining hash {} not found in the tracker for consumer {}", dispatcherName,
+ hash, consumer);
continue;
}
int unackedMessages = entry.getRefCount();