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 +}