(pulsar) branch master updated: [fix][broker] Fix AvgShedder strategy check (#23156)

[thetumbled]

This is an automated email from the ASF dual-hosted git repository.

thetumbled 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 66cc754006c [fix][broker] Fix AvgShedder strategy check (#23156)
66cc754006c is described below

commit 66cc754006ce95b8a7a90af31024462478831d7e
Author: Kai Wang <kw...@apache.org>
AuthorDate: Tue Aug 13 10:02:58 2024 +0800

    [fix][broker] Fix AvgShedder strategy check (#23156)
---
 .../apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java
index 141e020d7ca..05c984d0349 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java
@@ -275,11 +275,11 @@ public class ModularLoadManagerImpl implements 
ModularLoadManager {
             // if the placement strategy is also a load shedding strategy
             // we need to check two strategies are the same
             if (!conf.getLoadBalancerLoadSheddingStrategy().equals(
-                    conf.getLoadBalancerPlacementStrategy())) {
+                    conf.getLoadBalancerLoadPlacementStrategy())) {
                 throw new IllegalArgumentException("The load shedding 
strategy: "
                         + conf.getLoadBalancerLoadSheddingStrategy()
                         + " can't work with the placement strategy: "
-                        + conf.getLoadBalancerPlacementStrategy());
+                        + conf.getLoadBalancerLoadPlacementStrategy());
             }
             // bind the load shedding strategy and the placement strategy
             loadSheddingStrategy = (LoadSheddingStrategy) placementStrategy;