We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c4af9e6 commit 4b355a3Copy full SHA for 4b355a3
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java
@@ -322,7 +322,10 @@ public double getLedgerSwitchLatencyAverageUsec() {
322
323
@Override
324
public long getStoredMessagesSize() {
325
- return managedLedger.getTotalSize() * managedLedger.getConfig().getWriteQuorumSize();
+ long totalSize = managedLedger.getTotalSize();
326
+ long offloadedSize = managedLedger.getOffloadedSize();
327
+ long bookieSize = totalSize - offloadedSize;
328
+ return bookieSize * managedLedger.getConfig().getWriteQuorumSize() + offloadedSize;
329
}
330
331
0 commit comments