From 64c99d4ae7cd28d654893fa51d82c2a4ee1e11df Mon Sep 17 00:00:00 2001 From: Yunze Xu Date: Sat, 14 Feb 2026 10:43:46 +0800 Subject: [PATCH] [fix][test] Fix ResourceQuotaCalculatorImplTest#testNeedToReportLocalUsage --- .../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 eeda957bf3e22..7859066223e14 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 void testRQCalcGlobUsedZeroTest() throws PulsarAdminException { @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 void testNeedToReportLocalUsage() { } private ResourceQuotaCalculatorImpl rqCalc; -} \ No newline at end of file +}