You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2022/12/20 23:38:17 UTC
[pulsar] branch master updated: [improve][broker] Add logs for why namespace bundle been split (#19003)
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 8b66a21ef41 [improve][broker] Add logs for why namespace bundle been split (#19003)
8b66a21ef41 is described below
commit 8b66a21ef4101c5726b362788ca746d390c7bf38
Author: Penghui Li <pe...@apache.org>
AuthorDate: Wed Dec 21 07:38:08 2022 +0800
[improve][broker] Add logs for why namespace bundle been split (#19003)
---
.../apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java
index c0c6eebc32a..310f80d6f74 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java
@@ -102,6 +102,12 @@ public class BundleSplitterTask implements BundleSplitStrategy {
.getBundleCount(NamespaceName.get(namespace));
if ((bundleCount + namespaceBundleCount.getOrDefault(namespace, 0))
< maxBundleCount) {
+ log.info("The bundle {} is considered to be unload. Topics: {}/{}, Sessions: ({}+{})/{}, "
+ + "Message Rate: {}/{} (msgs/s), Message Throughput: {}/{} (MB/s)",
+ bundle, stats.topics, maxBundleTopics, stats.producerCount, stats.consumerCount,
+ maxBundleSessions, totalMessageRate, maxBundleMsgRate,
+ totalMessageThroughput / LoadManagerShared.MIBI,
+ maxBundleBandwidth / LoadManagerShared.MIBI);
bundleCache.add(bundle);
int bundleNum = namespaceBundleCount.getOrDefault(namespace, 0);
namespaceBundleCount.put(namespace, bundleNum + 1);