Skip to content

Commit 1309cba

Browse files
authored
[fix][ml] Corrected pulsar_storage_size metric to not multiply offloaded storage by the write quorum (#24054)
1 parent e517705 commit 1309cba

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -357,7 +357,10 @@ public double getLedgerSwitchLatencyAverageUsec() {
357357

358358
@Override
359359
public long getStoredMessagesSize() {
360-
return managedLedger.getTotalSize() * managedLedger.getConfig().getWriteQuorumSize();
360+
long totalSize = managedLedger.getTotalSize();
361+
long offloadedSize = managedLedger.getOffloadedSize();
362+
long bookieSize = totalSize - offloadedSize;
363+
return bookieSize * managedLedger.getConfig().getWriteQuorumSize() + offloadedSize;
361364
}
362365

363366
@Override

0 commit comments

Comments
 (0)