ensure deleted entries are deleted

fix https://github.com/seaweedfs/seaweedfs/issues/6936
This commit is contained in:
chrislu 2025-07-01 00:45:13 -07:00
parent 7ab3b19e37
commit e5adc3872a

View File

@ -299,7 +299,7 @@ func readNeedleMap(baseFileName string) (*needle_map.MemDb, error) {
cm := needle_map.NewMemDb()
err = idx.WalkIndexFile(indexFile, 0, func(key types.NeedleId, offset types.Offset, size types.Size) error {
if !offset.IsZero() && size != types.TombstoneFileSize {
if !offset.IsZero() && !size.IsDeleted() {
cm.Set(key, offset, size)
} else {
cm.Delete(key)