[pulsar] branch master updated: remove duplicate filter in OverloadShedder (#18463)

[zi...@apache.org]

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

zixuan 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 6efe57539d1 remove duplicate filter in OverloadShedder (#18463)
6efe57539d1 is described below

commit 6efe57539d13b07dd115e4e1fedbd3f646918e76
Author: LinChen <15...@qq.com>
AuthorDate: Tue Nov 15 15:42:30 2022 +0800

    remove duplicate filter in OverloadShedder (#18463)
    
    Co-authored-by: lordcheng10 <le...@tencent.com>
---
 .../org/apache/pulsar/broker/loadbalance/impl/OverloadShedder.java    | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedder.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedder.java
index 1ada186274c..a4eb5077224 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedder.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedder.java
@@ -114,9 +114,7 @@ public class OverloadShedder implements LoadSheddingStrategy {
                 }).filter(e -> {
                     // Only consider bundles that were not already unloaded recently
                     return !recentlyUnloadedBundles.containsKey(e.getLeft());
-                }).filter(e ->
-                        localData.getBundles().contains(e.getLeft())
-                ).sorted((e1, e2) -> {
+                }).sorted((e1, e2) -> {
                     // Sort by throughput in reverse order
                     return Double.compare(e2.getRight(), e1.getRight());
                 }).forEach(e -> {