From 9a8801e0b2d88720677b77c26cdb3612b9796f3b Mon Sep 17 00:00:00 2001 From: hangc0276 Date: Mon, 28 Jun 2021 19:12:57 +0800 Subject: [PATCH] fix flaky test testBrokerRanking (#11114) --- .../apache/pulsar/broker/loadbalance/LoadBalancerTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/LoadBalancerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/LoadBalancerTest.java index 175a1eb90fac49..64e0a63203b8e4 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/LoadBalancerTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/LoadBalancerTest.java @@ -303,7 +303,7 @@ private void printSortedRanking(AtomicReference>> so * bottleneck, for the 4/5th brokers CPU become bottleneck since memory is big enough - non-bundles assigned so all * idle resources are available for new bundle Check the broker rankings are the load percentage of each broker. */ - @Test + @Test(timeOut = 30000) public void testBrokerRanking() throws Exception { for (int i = 0; i < BROKER_COUNT; i++) { LoadReport lr = new LoadReport(); @@ -322,7 +322,7 @@ public void testBrokerRanking() throws Exception { for (int i = 0; i < BROKER_COUNT; i++) { Method updateRanking = Whitebox.getMethod(SimpleLoadManagerImpl.class, "updateRanking"); - updateRanking.invoke(pulsarServices[0].getLoadManager().get()); + updateRanking.invoke(pulsarServices[i].getLoadManager().get()); } // check the ranking result