Corrected total storage metric to not multiply offloaded storage by t…

…he write quorum
apache · Mar 4, 2025 · 09b589e · 09b589e
1 parent 966a396
commit 09b589e
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java
@@ -357,7 +357,10 @@ public double getLedgerSwitchLatencyAverageUsec() {
 
     @Override
     public long getStoredMessagesSize() {
-        return managedLedger.getTotalSize() * managedLedger.getConfig().getWriteQuorumSize();
+        long totalSize = managedLedger.getTotalSize();
+        long offloadedSize = managedLedger.getOffloadedSize();
+        long bookieSize = totalSize - offloadedSize;
+        return bookieSize * managedLedger.getConfig().getWriteQuorumSize() + offloadedSize;
     }
 
     @Override