We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 34c1918 commit d158d4cCopy full SHA for d158d4c
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java
@@ -312,7 +312,10 @@ public double getLedgerSwitchLatencyAverageUsec() {
312
313
@Override
314
public long getStoredMessagesSize() {
315
- return managedLedger.getTotalSize() * managedLedger.getConfig().getWriteQuorumSize();
+ long totalSize = managedLedger.getTotalSize();
316
+ long offloadedSize = managedLedger.getOffloadedSize();
317
+ long bookieSize = totalSize - offloadedSize;
318
+ return bookieSize * managedLedger.getConfig().getWriteQuorumSize() + offloadedSize;
319
}
320
321
0 commit comments