diff --git a/cs/src/core/Index/FasterLog/FasterLog.cs b/cs/src/core/Index/FasterLog/FasterLog.cs index fc963cb3d..b33612bc2 100644 --- a/cs/src/core/Index/FasterLog/FasterLog.cs +++ b/cs/src/core/Index/FasterLog/FasterLog.cs @@ -54,6 +54,7 @@ public FasterLog(FasterLogSettings logSettings) logSettings.LogDevice.FileName + ".commit"); epoch = new LightEpoch(); + CommittedUntilAddress = Constants.kFirstValidAddress; allocator = new BlittableAllocator( logSettings.GetLogSettings(), null, null, epoch, e => Commit(e)); @@ -316,6 +317,7 @@ private void Restore() allocator.RestoreHybridLog(info.FlushedUntilAddress, info.FlushedUntilAddress - allocator.GetOffsetInPage(info.FlushedUntilAddress), info.BeginAddress); + CommittedUntilAddress = info.FlushedUntilAddress; } } }