Skip to content

Commit edd51a3

Browse files
author
fanjianye
committed
different bookie trigger gcOverreplicatedLedger randomly
1 parent 01c9149 commit edd51a3

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/ScanAndCompareGarbageCollector.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,9 +94,10 @@ public ScanAndCompareGarbageCollector(LedgerManager ledgerManager, CompactableLe
9494
this.selfBookieAddress = BookieImpl.getBookieId(conf);
9595

9696
this.gcOverReplicatedLedgerIntervalMillis = conf.getGcOverreplicatedLedgerWaitTimeMillis();
97-
this.lastOverReplicatedLedgerGcTimeMillis = System.currentTimeMillis();
9897
if (gcOverReplicatedLedgerIntervalMillis > 0) {
9998
this.enableGcOverReplicatedLedger = true;
99+
this.lastOverReplicatedLedgerGcTimeMillis = System.currentTimeMillis() +
100+
(long)(gcOverReplicatedLedgerIntervalMillis * Math.random());
100101
}
101102
this.maxConcurrentRequests = conf.getGcOverreplicatedLedgerMaxConcurrentRequests();
102103
LOG.info("Over Replicated Ledger Deletion : enabled={}, interval={}, maxConcurrentRequests={}",

0 commit comments

Comments
 (0)