You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2022/08/21 13:35:52 UTC
[pulsar] 05/05: [fix][flaky-test] Fix flaky test testBacklogNoDelayedForPartitionedTopic (#17180)
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit bbcda2607a9d0a3b1b38fb1cdeaecfd534d48fb0
Author: gaozhangmin <zh...@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 9db6821076a..5e46ff94768 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
@@ -1656,11 +1656,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());