You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ji...@apache.org on 2022/09/04 13:27:42 UTC
[pulsar] 01/02: [fix][flaky-test] Fix flaky test testBacklogNoDelayedForPartitionedTopic (#17180)
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 <zh...@apache.org>
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());