We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent de8a2a4 commit 3d1b573Copy full SHA for 3d1b573
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