This is an automated email from the ASF dual-hosted git repository.
bogong pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.9 by this push:
new ba2d9dbe7c5 [fix][flaky-test] Fix flaky test
testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#16419)
ba2d9dbe7c5 is described below
commit ba2d9dbe7c5669d9d94ea8c9c0c0e756d2c37751
Author: gaozhangmin <[email protected]>
AuthorDate: Wed Jul 13 13:12:06 2022 +0800
[fix][flaky-test] Fix flaky test
testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#16419)
Co-authored-by: gavingaozhangmin <[email protected]>
(cherry picked from commit 28ff97aa2e5f0e9518887c19d9a888cc9dc02009)
---
.../java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
index 781a90a1c10..f313a0f5d87 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
@@ -508,6 +508,7 @@ public class BacklogQuotaManagerTest {
.limitTime(TIME_TO_CHECK_BACKLOG_QUOTA)
.retentionPolicy(BacklogQuota.RetentionPolicy.consumer_backlog_eviction)
.build(), BacklogQuota.BacklogQuotaType.message_age);
+ config.setPreciseTimeBasedBacklogQuotaCheck(true);
PulsarClient client =
PulsarClient.builder().serviceUrl(adminUrl.toString()).statsInterval(0,
TimeUnit.SECONDS)
.build();