diff --git a/cs/src/core/FasterLog/FasterLog.cs b/cs/src/core/FasterLog/FasterLog.cs index e5875dc93..f36a45a0b 100644 --- a/cs/src/core/FasterLog/FasterLog.cs +++ b/cs/src/core/FasterLog/FasterLog.cs @@ -1918,6 +1918,8 @@ private void RestoreLatest(out Dictionary iterators, out byte[] co iterators = CompleteRestoreFromCommit(info); cookie = info.Cookie; commitNum = info.CommitNum; + // After recovery persisted commitnum remians 0 so we need to set it to latest commit number + persistedCommitNum = info.CommitNum; beginAddress = allocator.BeginAddress; if (readOnlyMode) allocator.HeadAddress = long.MaxValue;