address comment

apache · Nov 16, 2022 · bad27a2 · bad27a2
1 parent 975f159
commit bad27a2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...r-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedderTest.java b/...r-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedderTest.java
@@ -68,6 +68,7 @@ public void testBrokerNotOverloaded() {
         LocalBrokerData broker1 = new LocalBrokerData();
         broker1.setBandwidthIn(new ResourceUsage(500, 1000));
         broker1.setBandwidthOut(new ResourceUsage(500, 1000));
+        broker1.getBundles().clear();
         broker1.getBundles().add("bundle-1");
 
         BundleData bundle1 = new BundleData();
@@ -89,6 +90,7 @@ public void testBrokerWithSingleBundle() {
         LocalBrokerData broker1 = new LocalBrokerData();
         broker1.setBandwidthIn(new ResourceUsage(999, 1000));
         broker1.setBandwidthOut(new ResourceUsage(999, 1000));
+        broker1.getBundles().clear();
         broker1.getBundles().add("bundle-1");
 
         BundleData bundle1 = new BundleData();

diff --git a/...-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/ThresholdShedderTest.java b/...-broker/src/test/java/org/apache/pulsar/broker/loadbalance/impl/ThresholdShedderTest.java
@@ -78,6 +78,7 @@ public void testBrokerNotReachThreshold() {
         broker1.setDirectMemory(new ResourceUsage(5000, 100));
         broker1.setBandwidthIn(new ResourceUsage(500, 1000));
         broker1.setBandwidthOut(new ResourceUsage(500, 1000));
+        broker1.getBundles().clear();
         broker1.getBundles().add("bundle-1");
 
         BundleData bundleData = new BundleData();
@@ -98,6 +99,7 @@ public void testBrokerWithSingleBundle() {
         LocalBrokerData broker1 = new LocalBrokerData();
         broker1.setBandwidthIn(new ResourceUsage(999, 1000));
         broker1.setBandwidthOut(new ResourceUsage(999, 1000));
+        broker1.getBundles().clear();
         broker1.getBundles().add("bundle-1");
 
         BundleData bundle1 = new BundleData();