You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/12/21 01:27:31 UTC
[pulsar] branch branch-2.10 updated: [improve][broker] Add logs for why namespace bundle been split (#19003)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.10 by this push:
new af0bc205e01 [improve][broker] Add logs for why namespace bundle been split (#19003)
af0bc205e01 is described below
commit af0bc205e01bd4990adb3794adab9e1fa4f02a79
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)
(cherry picked from commit 8b66a21ef4101c5726b362788ca746d390c7bf38)
---
.../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 2203dbafc37..3c373188c8d 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
@@ -100,6 +100,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);