diff --git a/libs/storage/Tsavorite/cs/src/core/TsavoriteLog/TsavoriteLogIterator.cs b/libs/storage/Tsavorite/cs/src/core/TsavoriteLog/TsavoriteLogIterator.cs index 8cf87a8cb..923842467 100644 --- a/libs/storage/Tsavorite/cs/src/core/TsavoriteLog/TsavoriteLogIterator.cs +++ b/libs/storage/Tsavorite/cs/src/core/TsavoriteLog/TsavoriteLogIterator.cs @@ -378,7 +378,7 @@ public unsafe bool GetNext(MemoryPool pool, out IMemoryOwner entry, if (isCommitRecord) { TsavoriteLogRecoveryInfo info = new(); - info.Initialize(new ReadOnlySpan((byte*)physicalAddress, entryLength)); + info.Initialize(new ReadOnlySpan((byte*)(headerSize + physicalAddress), entryLength)); if (info.CommitNum != long.MaxValue) continue; // Otherwise, no more entries @@ -441,7 +441,7 @@ public unsafe bool GetNext(MemoryPool pool, out IMemoryOwner entry, if (isCommitRecord) { TsavoriteLogRecoveryInfo info = new(); - info.Initialize(new ReadOnlySpan((byte*)physicalAddress, entryLength)); + info.Initialize(new ReadOnlySpan((byte*)(headerSize + physicalAddress), entryLength)); if (info.CommitNum != long.MaxValue) continue; // Otherwise, no more entries