diff --git a/weed/storage/disk_location.go b/weed/storage/disk_location.go index 99c4f3c34..c656da4ca 100644 --- a/weed/storage/disk_location.go +++ b/weed/storage/disk_location.go @@ -168,6 +168,7 @@ func (l *DiskLocation) UnloadVolume(vid VolumeId) error { if !ok { return fmt.Errorf("Volume not loaded, VolumeId: %d", vid) } + l.volumes[vid].Close() delete(l.volumes, vid) return nil }