This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit fbaaac5ed8cd4c742bf3bd269cd9c09549da6007 Author: dong_zhong_hua <[email protected]> AuthorDate: Fri Nov 7 01:01:30 2025 +0800 [fix][broker] AvgShedder comparison error (#24954) Co-authored-by: dongzhonghua03 <[email protected]> (cherry picked from commit 186b503579f67bc0eaffc99a7e45026e5c3116ab) --- .../java/org/apache/pulsar/broker/loadbalance/impl/AvgShedder.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/AvgShedder.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/AvgShedder.java index 39ff242fc6c..53f5c014761 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/AvgShedder.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/AvgShedder.java @@ -25,6 +25,7 @@ import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; +import java.util.Comparator; import java.util.HashMap; import java.util.LinkedList; import java.util.List; @@ -224,7 +225,7 @@ public class AvgShedder implements LoadSheddingStrategy, ModularLoadManagerStrat } // sort brokers by scores. - return brokerScoreMap.entrySet().stream().sorted((o1, o2) -> (int) (o1.getValue() - o2.getValue())) + return brokerScoreMap.entrySet().stream().sorted(Comparator.comparingDouble(Map.Entry::getValue)) .map(Map.Entry::getKey).toList(); }
