This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 1b1c58a7887c62896a7fb7c409b904d6086dbb01 Author: Yunze Xu <[email protected]> AuthorDate: Mon Feb 16 16:38:19 2026 +0800 [fix][test] Fix ResourceQuotaCalculatorImplTest#testNeedToReportLocalUsage (#25247) (cherry picked from commit 48774deca8691cba964397c53ac19838796b2d77) --- .../pulsar/broker/resourcegroup/ResourceQuotaCalculatorImplTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/resourcegroup/ResourceQuotaCalculatorImplTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/resourcegroup/ResourceQuotaCalculatorImplTest.java index eeda957bf3e..7859066223e 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/resourcegroup/ResourceQuotaCalculatorImplTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/resourcegroup/ResourceQuotaCalculatorImplTest.java @@ -113,6 +113,9 @@ public class ResourceQuotaCalculatorImplTest extends MockedPulsarServiceBaseTest @Test public void testNeedToReportLocalUsage() { + // This field is 0 when the schedulers of `ResourceGroupService` are not started, then `needToReportLocalUsage` + // will always return true. Set it to a non-zero value to test the percentage change logic. + ResourceGroupService.maxIntervalForSuppressingReportsMSecs = 60 * 1000L; // 1 minute // If the percentage change (increase or decrease) in usage is more than 5% for // either bytes or messages, send a report. Assert.assertFalse(rqCalc.needToReportLocalUsage(1040, 1000, 104, 100, System.currentTimeMillis())); @@ -122,4 +125,4 @@ public class ResourceQuotaCalculatorImplTest extends MockedPulsarServiceBaseTest } private ResourceQuotaCalculatorImpl rqCalc; -} \ No newline at end of file +}
