We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9ab3221 commit c4b8ca9Copy full SHA for c4b8ca9
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java
@@ -357,7 +357,10 @@ public double getLedgerSwitchLatencyAverageUsec() {
357
358
@Override
359
public long getStoredMessagesSize() {
360
- return managedLedger.getTotalSize() * managedLedger.getConfig().getWriteQuorumSize();
+ long totalSize = managedLedger.getTotalSize();
361
+ long offloadedSize = managedLedger.getOffloadedSize();
362
+ long bookieSize = totalSize - offloadedSize;
363
+ return bookieSize * managedLedger.getConfig().getWriteQuorumSize() + offloadedSize;
364
}
365
366
0 commit comments