(pulsar) branch branch-3.0 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 branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 0fa9572f8af [fix][broker] Fix AvgShedder strategy check (#23156)
0fa9572f8af is described below

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

    [fix][broker] Fix AvgShedder strategy check (#23156)
    
    (cherry picked from commit 66cc754006ce95b8a7a90af31024462478831d7e)
---
 .../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 72300f3d857..52706a1b02b 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
@@ -284,11 +284,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
             loadSheddingPipeline.add((LoadSheddingStrategy) placementStrategy);