enh: keep extra raft Logs before minimum match index

eca97bf5 · Benguang Zhao · 21c18a4a · eca97bf5
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/sync/src/syncMain.c source/libs/sync/src/syncMain.c +1 -1

未找到文件。
--- a/source/libs/sync/src/syncMain.c
+++ b/source/libs/sync/src/syncMain.c
@@ -301,7 +301,7 @@ int32_t syncBeginSnapshot(int64_t rid, int64_t lastApplyIndex) {
      syncNodeRelease(pSyncNode);
      return 0;
    }
-    logRetention = TMAX(logRetention, lastApplyIndex - pSyncNode->minMatchIndex);
+    logRetention = TMAX(logRetention, lastApplyIndex - pSyncNode->minMatchIndex + logRetention);
  }
 _DEL_WAL: