From 09b589ee757c6319402f06d4828b0228af92c764 Mon Sep 17 00:00:00 2001 From: Andrey Yegorov Date: Mon, 3 Mar 2025 16:20:43 -0800 Subject: [PATCH] Corrected total storage metric to not multiply offloaded storage by the write quorum --- .../bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java | 5 ++++- 1 file changed, 4 insertions(+), 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 index 86320f9292468..634afccf6ac39 100644 --- 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