You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2022/07/13 05:12:13 UTC
[pulsar] branch master updated: [fix][flaky-test] Fix flaky test testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#16419)
This is an automated email from the ASF dual-hosted git repository.
zhangmingao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 28ff97aa2e5 [fix][flaky-test] Fix flaky test testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#16419)
28ff97aa2e5 is described below
commit 28ff97aa2e5f0e9518887c19d9a888cc9dc02009
Author: gaozhangmin <ga...@qq.com>
AuthorDate: Wed Jul 13 13:12:06 2022 +0800
[fix][flaky-test] Fix flaky test testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#16419)
Co-authored-by: gavingaozhangmin <ga...@didiglobal.com>
---
.../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 f51dcf42c5d..57d5f0dfd50 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
@@ -528,6 +528,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();