From e5ce0b697c4f9cebff635897005c22d17d5122a7 Mon Sep 17 00:00:00 2001 From: gavingaozhangmin Date: Fri, 19 Aug 2022 16:04:17 +0800 Subject: [PATCH] [fix][flaky-test] Fix flaky test testBacklogNoDelayedForPartitionedTopic --- .../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 1128911911722..580aa90693656 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 void testBacklogNoDelayedForPartitionedTopic() throws PulsarClientExcepti 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());