Remove unnecessary sleep

apache · Jun 29, 2023 · 04261c8 · 04261c8
1 parent 94baf21
commit 04261c8
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerStatTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerStatTest.java
@@ -548,8 +548,6 @@ public void testMsgRateExpired() throws Exception {
         Awaitility.await().ignoreExceptions().timeout(10, TimeUnit.SECONDS)
                 .until(() -> pulsar.getBrokerService().getTopicStats().get(topicName).getSubscriptions().get(subName).getTotalMsgExpired() > 0);
 
-        Thread.sleep(2000);
-
         Awaitility.await().ignoreExceptions().timeout(10, TimeUnit.SECONDS).until(() -> {
             pulsar.getBrokerService().updateRates();
             return pulsar.getBrokerService().getTopicStats().get(topicName).getSubscriptions().get(subName).getMsgRateExpired() < 0.001;