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/03/14 23:26:45 UTC

[pulsar] branch master updated: Change "Could not split namespace bundle" logging level to debug (#14683)

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 e61422c  Change "Could not split namespace bundle" logging level to debug (#14683)
e61422c is described below

commit e61422c53e9ab020b40016f0c902b72c3263e6fa
Author: Michael Marshall <mm...@apache.org>
AuthorDate: Mon Mar 14 18:17:10 2022 -0500

    Change "Could not split namespace bundle" logging level to debug (#14683)
---
 .../apache/pulsar/broker/loadbalance/impl/BundleSplitterTask.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

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 7ea0f1b..ac78cec 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
@@ -94,9 +94,11 @@ public class BundleSplitterTask implements BundleSplitStrategy {
                         if (bundleCount < maxBundleCount) {
                             bundleCache.add(bundle);
                         } else {
-                            log.info(
-                                    "Could not split namespace bundle {} because namespace {} has too many bundles: {}",
-                                    bundle, namespace, bundleCount);
+                            if (log.isDebugEnabled()) {
+                                log.debug(
+                                        "Could not split namespace bundle {} because namespace {} has too many bundles:"
+                                                + "{}", bundle, namespace, bundleCount);
+                            }
                         }
                     } catch (Exception e) {
                         log.warn("Error while getting bundle count for namespace {}", namespace, e);