diff options
| author | chrislu <chris.lu@gmail.com> | 2025-10-26 09:44:43 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-10-26 09:44:43 -0700 |
| commit | 3843a75ac6009e1b48f82ee515accc4969c68ed9 (patch) | |
| tree | 3c13abf244d0d5fbbd11889934d5b0046da9d7fc | |
| parent | 1a124d1fd8b193b8b10f2f88ec08a3848269fd5b (diff) | |
| download | seaweedfs-3843a75ac6009e1b48f82ee515accc4969c68ed9.tar.xz seaweedfs-3843a75ac6009e1b48f82ee515accc4969c68ed9.zip | |
in memory cleanup
| -rw-r--r-- | weed/storage/disk_location_ec.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/storage/disk_location_ec.go b/weed/storage/disk_location_ec.go index ad4f82f98..47b7f8e29 100644 --- a/weed/storage/disk_location_ec.go +++ b/weed/storage/disk_location_ec.go @@ -246,6 +246,8 @@ func (l *DiskLocation) loadAllEcShards() (err error) { if util.FileExists(datFileName) { glog.Warningf("Found %d EC shards without .ecx file for volume %d (incomplete encoding interrupted before .ecx creation), cleaning up...", len(sameVolumeShards), volumeId) + // Clean up any in-memory state before removing files + l.DestroyEcVolume(volumeId) l.removeEcVolumeFiles(collection, volumeId) } } |