diff --git a/weed/storage/erasure_coding/ec_decoder.go b/weed/storage/erasure_coding/ec_decoder.go index abba2526b..1802cf36c 100644 --- a/weed/storage/erasure_coding/ec_decoder.go +++ b/weed/storage/erasure_coding/ec_decoder.go @@ -230,9 +230,9 @@ func WriteDatFileAndVacuum(baseFileName string, shardFileNames []string) error { } defer os.Remove(tempDatFile) // cleanup temp file - // Step 2: Create index file with deleted entries marked (existing function) + // Step 2: Create index file with deleted entries marked (use actual .ecx/.ecj files directly) tempIdxFile := baseFileName + ".tmp.idx" - err = WriteIdxFileFromEcIndex(baseFileName + ".tmp") + err = WriteIdxFileFromEcIndex(baseFileName) // Use actual .ecx/.ecj files directly if err != nil { return fmt.Errorf("failed to create index file: %w", err) }