You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zi...@apache.org on 2022/08/16 10:52:58 UTC
[pulsar] branch master updated: [pulsar-broker] Change dispatcher blocked/unblocked log level to debug (#15767)
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()) {