fix

CascadingRadium · CascadingRadium · commit c533b5617af2 · 2026-07-09T17:29:45.000+05:30
diff --git a/index/scorch/merge.go b/index/scorch/merge.go
@@ -438,14 +438,12 @@ func (s *Scorch) planMergeAtSnapshot(ctrlMsg *mergerCtrl, ourSnapshot *IndexSnap
 			atomic.StoreUint64(&s.stats.MaxFileMergeZapTime, fileMergeZapTime)
 		}
 		if err != nil {
-			s.unmarkIneligibleForRemoval(batch.newFilename)
 			atomic.AddUint64(&s.stats.TotFileMergePlanTasksErr, 1)
 			return err
 		}
 
 		batch.new, err = s.segPlugin.OpenUsing(path, s.segmentConfig)
 		if err != nil {
-			s.unmarkIneligibleForRemoval(batch.newFilename)
 			atomic.AddUint64(&s.stats.TotFileMergePlanTasksErr, 1)
 			return err
 		}

Original file line number	Diff line number	Diff line change
`@@ -438,14 +438,12 @@ func (s Scorch) planMergeAtSnapshot(ctrlMsg mergerCtrl, ourSnapshot *IndexSnap`
`438`	`438`	`atomic.StoreUint64(&s.stats.MaxFileMergeZapTime, fileMergeZapTime)`
`439`	`439`	`}`
`440`	`440`	`if err != nil {`
`441`		`- s.unmarkIneligibleForRemoval(batch.newFilename)`
`442`	`441`	`atomic.AddUint64(&s.stats.TotFileMergePlanTasksErr, 1)`
`443`	`442`	`return err`
`444`	`443`	`}`
`445`	`444`
`446`	`445`	`batch.new, err = s.segPlugin.OpenUsing(path, s.segmentConfig)`
`447`	`446`	`if err != nil {`
`448`		`- s.unmarkIneligibleForRemoval(batch.newFilename)`
`449`	`447`	`atomic.AddUint64(&s.stats.TotFileMergePlanTasksErr, 1)`
`450`	`448`	`return err`
`451`	`449`	`}`