fix(engine): remove SeriesIDSets check in deletion
We leave in the options and stuff for now as it's tied in with a lot of the tests/multiple shard stuff that will be removed eventually, anyway.pull/10616/head
parent
29efd46527
commit
eeb9580bff
|
@ -183,9 +183,6 @@ type Engine struct {
|
|||
compactionLimiter limiter.Fixed
|
||||
|
||||
scheduler *scheduler
|
||||
|
||||
// provides access to the total set of series IDs
|
||||
seriesIDSets tsdb.SeriesIDSets
|
||||
}
|
||||
|
||||
// NewEngine returns a new instance of Engine.
|
||||
|
@ -235,7 +232,6 @@ func NewEngine(id uint64, idx tsdb.Index, path string, walPath string, sfile *ts
|
|||
stats: stats,
|
||||
compactionLimiter: opt.CompactionLimiter,
|
||||
scheduler: newScheduler(stats, opt.CompactionLimiter.Capacity()),
|
||||
seriesIDSets: opt.SeriesIDSets,
|
||||
}
|
||||
|
||||
if opt.WALEnabled {
|
||||
|
@ -1608,14 +1604,6 @@ func (e *Engine) deleteSeriesRange(seriesKeys [][]byte, min, max int64) error {
|
|||
}
|
||||
}
|
||||
|
||||
// Remove any series IDs for our set that still exist in other shards.
|
||||
// We cannot remove these from the series file yet.
|
||||
if err := e.seriesIDSets.ForEach(func(s *tsdb.SeriesIDSet) {
|
||||
ids = ids.AndNot(s)
|
||||
}); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// Remove the remaining ids from the series file as they no longer exist
|
||||
// in any shard.
|
||||
var err error
|
||||
|
|
Loading…
Reference in New Issue