[ISSUE openmessaging#316] fix committedIndex after truncate

yuz10 · Feb 22, 2024 · c89b06d · c89b06d
1 parent d34f270
commit c89b06d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dledger/src/main/java/io/openmessaging/storage/dledger/store/file/DLedgerMmapFileStore.java b/dledger/src/main/java/io/openmessaging/storage/dledger/store/file/DLedgerMmapFileStore.java
@@ -425,6 +425,9 @@ public long truncate(DLedgerEntry entry, long leaderTerm, String leaderId) {
             PreConditions.check(indexPos == entry.getIndex() * INDEX_UNIT_SIZE, DLedgerResponseCode.DISK_ERROR, null);
             ledgerEndTerm = entry.getTerm();
             ledgerEndIndex = entry.getIndex();
+            if (committedIndex > ledgerEndIndex) {
+                committedIndex = ledgerEndIndex;
+            }
             reviseLedgerBeforeBeginIndex();
             updateLedgerEndIndexAndTerm();
             return entry.getIndex();