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


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

commit dd380ec7cee79bb05578c35333e563059add6ca9
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 735319c7995..417cb85a74b 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
@@ -271,11 +271,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);