[pulsar] branch master updated: [fix][flaky-test] Fix flaky test testBacklogNoDelayedForPartitionedTopic (#17180)

[technoboy]

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

technoboy 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 1faf497ce29 [fix][flaky-test] Fix flaky test 
testBacklogNoDelayedForPartitionedTopic (#17180)
1faf497ce29 is described below

commit 1faf497ce29ca573ebf354396cf73691b27d5fc3
Author: gaozhangmin <zhangmin...@apache.org>
AuthorDate: Sun Aug 21 10:01:22 2022 +0800

    [fix][flaky-test] Fix flaky test testBacklogNoDelayedForPartitionedTopic 
(#17180)
---
 .../java/org/apache/pulsar/broker/admin/AdminApi2Test.java   | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApi2Test.java 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApi2Test.java
index 11289119117..580aa906936 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApi2Test.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApi2Test.java
@@ -1669,11 +1669,13 @@ public class AdminApi2Test extends 
MockedPulsarServiceBaseTest {
                 producer.send("message-1".getBytes(StandardCharsets.UTF_8));
             }
         }
-
-        TopicStats topicStats = admin.topics().getPartitionedStats(topic, 
false, true, true, true);
-        
assertEquals(topicStats.getSubscriptions().get(subName).getMsgBacklog(), 10);
-        
assertEquals(topicStats.getSubscriptions().get(subName).getBacklogSize(), 440);
-        
assertEquals(topicStats.getSubscriptions().get(subName).getMsgBacklogNoDelayed(),
 5);
+        // wait until the message add to delay queue.
+        Awaitility.await().untilAsserted(() -> {
+            TopicStats topicStats = admin.topics().getPartitionedStats(topic, 
false, true, true, true);
+            
assertEquals(topicStats.getSubscriptions().get(subName).getMsgBacklog(), 10);
+            
assertEquals(topicStats.getSubscriptions().get(subName).getBacklogSize(), 440);
+            
assertEquals(topicStats.getSubscriptions().get(subName).getMsgBacklogNoDelayed(),
 5);
+        });
 
         for (int i = 0; i < 5; i++) {
             consumer.acknowledge(consumer.receive());