[pulsar] branch master updated: [pulsar-broker] Change dispatcher blocked/unblocked log level to debug (#15767)

[zike]

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

zike 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 4d7b1acff35 [pulsar-broker] Change dispatcher blocked/unblocked log 
level to debug (#15767)
4d7b1acff35 is described below

commit 4d7b1acff35a1a131ffeff34e8cec6007f6a2ec9
Author: 萧易客 <km...@live.com>
AuthorDate: Tue Aug 16 18:52:48 2022 +0800

    [pulsar-broker] Change dispatcher blocked/unblocked log level to debug 
(#15767)
    
    ### Motivation
    
    There are so many dispatcher blocked/unblocked log(more than 30K within 15 
min), I supposed change it to debug.
---
 .../service/persistent/PersistentDispatcherMultipleConsumers.java   | 6 +++---
 .../persistent/PersistentStreamingDispatcherMultipleConsumers.java  | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

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 7ed277ddfda..34f63e392dc 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
@@ -932,8 +932,8 @@ public class PersistentDispatcherMultipleConsumers extends 
AbstractDispatcherMul
         if (unAckedMessages >= maxUnackedMessages && maxUnackedMessages > 0
                 && BLOCKED_DISPATCHER_ON_UNACKMSG_UPDATER.compareAndSet(this, 
FALSE, TRUE)) {
             // block dispatcher if it reaches maxUnAckMsg limit
-            log.info("[{}] Dispatcher is blocked due to unackMessages {} 
reached to max {}", name,
-                    TOTAL_UNACKED_MESSAGES_UPDATER.get(this), 
maxUnackedMessages);
+            log.debug("[{}] Dispatcher is blocked due to unackMessages {} 
reached to max {}", name,
+                    unAckedMessages, maxUnackedMessages);
         } else if (topic.getBrokerService().isBrokerDispatchingBlocked()
                 && blockedDispatcherOnUnackedMsgs == TRUE) {
             // unblock dispatcher: if dispatcher is blocked due to 
broker-unackMsg limit and if it ack back enough
@@ -947,7 +947,7 @@ public class PersistentDispatcherMultipleConsumers extends 
AbstractDispatcherMul
         } else if (blockedDispatcherOnUnackedMsgs == TRUE && unAckedMessages < 
maxUnackedMessages / 2) {
             // unblock dispatcher if it acks back enough messages
             if (BLOCKED_DISPATCHER_ON_UNACKMSG_UPDATER.compareAndSet(this, 
TRUE, FALSE)) {
-                log.info("[{}] Dispatcher is unblocked", name);
+                log.debug("[{}] Dispatcher is unblocked", name);
                 readMoreEntriesAsync();
             }
         }
diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
index 5235c13dc81..ed637b46379 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStreamingDispatcherMultipleConsumers.java
@@ -172,7 +172,7 @@ public class PersistentStreamingDispatcherMultipleConsumers 
extends PersistentDi
                     topic.getBrokerService().executor().execute(() -> 
readMoreEntries());
                 }
             } else if (BLOCKED_DISPATCHER_ON_UNACKMSG_UPDATER.get(this) == 
TRUE) {
-                log.warn("[{}] Dispatcher read is blocked due to unackMessages 
{} reached to max {}", name,
+                log.debug("[{}] Dispatcher read is blocked due to 
unackMessages {} reached to max {}", name,
                         totalUnackedMessages, 
topic.getMaxUnackedMessagesOnSubscription());
             } else if (!havePendingRead) {
                 if (log.isDebugEnabled()) {