This is an automated email from the ASF dual-hosted git repository. jianghaiting pushed a commit to branch branch-2.10 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 4c6417ab7e18fad181e47ffd714c0bf60a183579 Author: gaozhangmin <[email protected]> AuthorDate: Sun Aug 21 10:01:22 2022 +0800 [fix][flaky-test] Fix flaky test testBacklogNoDelayedForPartitionedTopic (#17180) (cherry picked from commit 1faf497ce29ca573ebf354396cf73691b27d5fc3) --- .../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 af518a36b31..62aed23ea4c 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 @@ -1653,11 +1653,13 @@ public class AdminApi2Test extends MockedPulsarServiceBaseTest { producer.send("message-1".getBytes(StandardCharsets.UTF_8)); } } - - TopicStats topicStats = admin.topics().getPartitionedStats(topic, false, 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); + 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());
