different bookie trigger gcOverreplicatedLedger randomly

TakaHiR07 · Apr 28, 2024 · 22fdca5 · 22fdca5
1 parent 01c9149
commit 22fdca5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...per-server/src/main/java/org/apache/bookkeeper/bookie/ScanAndCompareGarbageCollector.java b/...per-server/src/main/java/org/apache/bookkeeper/bookie/ScanAndCompareGarbageCollector.java
@@ -94,9 +94,10 @@ public ScanAndCompareGarbageCollector(LedgerManager ledgerManager, CompactableLe
         this.selfBookieAddress = BookieImpl.getBookieId(conf);
 
         this.gcOverReplicatedLedgerIntervalMillis = conf.getGcOverreplicatedLedgerWaitTimeMillis();
-        this.lastOverReplicatedLedgerGcTimeMillis = System.currentTimeMillis();
         if (gcOverReplicatedLedgerIntervalMillis > 0) {
             this.enableGcOverReplicatedLedger = true;
+            this.lastOverReplicatedLedgerGcTimeMillis = System.currentTimeMillis()
+                    + (long) (gcOverReplicatedLedgerIntervalMillis * Math.random());
         }
         this.maxConcurrentRequests = conf.getGcOverreplicatedLedgerMaxConcurrentRequests();
         LOG.info("Over Replicated Ledger Deletion : enabled={}, interval={}, maxConcurrentRequests={}",