This is an automated email from the ASF dual-hosted git repository.
xyz 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 882ce415c94 [improve][broker] Apply loadBalancerDebugModeEnabled in
LeastResourceUsageWithWeight (#22549)
882ce415c94 is described below
commit 882ce415c94db215c6f06aa5212b6d321231e35e
Author: Yunze Xu <[email protected]>
AuthorDate: Tue Apr 23 13:42:22 2024 +0800
[improve][broker] Apply loadBalancerDebugModeEnabled in
LeastResourceUsageWithWeight (#22549)
---
.../loadbalance/extensions/strategy/LeastResourceUsageWithWeight.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/strategy/LeastResourceUsageWithWeight.java
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/strategy/LeastResourceUsageWithWeight.java
index 98986d84b98..9bf16ac1795 100644
---
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/strategy/LeastResourceUsageWithWeight.java
+++
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/strategy/LeastResourceUsageWithWeight.java
@@ -96,8 +96,7 @@ public class LeastResourceUsageWithWeight implements
BrokerSelectionStrategy {
// select one of them at the end.
double totalUsage = 0.0d;
- // TODO: use loadBalancerDebugModeEnabled too.
- boolean debugMode = log.isDebugEnabled();
+ boolean debugMode = log.isDebugEnabled() ||
conf.isLoadBalancerDebugModeEnabled();
for (String broker : candidates) {
var brokerLoadDataOptional =
context.brokerLoadDataStore().get(broker);
if (brokerLoadDataOptional.isEmpty()) {