This is an automated email from the ASF dual-hosted git repository. shoothzj pushed a commit to branch improve-aging-logic in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 2e6c7845e05e29cb8b2e96dc626c7134a64912c1 Author: ZhangJian He <[email protected]> AuthorDate: Wed Aug 31 07:52:07 2022 +0800 Don't check Topic TimeLimit when quota limitTime less than 0 --- .../java/org/apache/pulsar/broker/service/BacklogQuotaManager.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java index 805d00adca6..d87025c2d9b 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java @@ -207,7 +207,7 @@ public class BacklogQuotaManager { ); } else { // If disabled precise time based backlog quota check, will try to remove whole ledger from cursor's backlog - Long currentMillis = ((ManagedLedgerImpl) persistentTopic.getManagedLedger()).getClock().millis(); + long currentMillis = ((ManagedLedgerImpl) persistentTopic.getManagedLedger()).getClock().millis(); ManagedLedgerImpl mLedger = (ManagedLedgerImpl) persistentTopic.getManagedLedger(); try { for (;;) { @@ -220,6 +220,8 @@ public class BacklogQuotaManager { } // Timestamp only > 0 if ledger has been closed if (ledgerInfo.getTimestamp() > 0 + // less than 0 means no limitation + && quota.getLimitTime() > 0 && currentMillis - ledgerInfo.getTimestamp() > quota.getLimitTime()) { // skip whole ledger for the slowest cursor PositionImpl nextPosition = mLedger.getNextValidPosition(
