remove duplicate filter in OverloadShedder (#18463)

Co-authored-by: lordcheng10 <leolinchen@tencent.com>
apache · Nov 15, 2022 · 6efe575 · 6efe575
1 parent 7712aa3
commit 6efe575
Showing 1 changed file with 1 addition and 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
@@ -114,9 +114,7 @@ public Multimap<String, String> findBundlesForUnloading(final LoadData loadData,
                 }).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 -> {