Merge pull request #9168 from influxdata/jw-delete-sort
Ensure series keys are sorted before searchingpull/8015/head
commit
5032a802d6
|
@ -338,6 +338,11 @@ func (s *LocalServer) Reset() error {
|
|||
func (s *LocalServer) WritePoints(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, user meta.User, points []models.Point) error {
|
||||
s.mu.RLock()
|
||||
defer s.mu.RUnlock()
|
||||
|
||||
if s.PointsWriter == nil {
|
||||
return fmt.Errorf("server closed")
|
||||
}
|
||||
|
||||
return s.PointsWriter.WritePoints(database, retentionPolicy, consistencyLevel, user, points)
|
||||
}
|
||||
|
||||
|
|
|
@ -1184,6 +1184,9 @@ func (e *Engine) deleteSeriesRange(seriesKeys [][]byte, min, max int64) error {
|
|||
return nil
|
||||
})
|
||||
|
||||
// Sort the series keys because ApplyEntryFn iterates over the keys randomly.
|
||||
bytesutil.Sort(deleteKeys)
|
||||
|
||||
e.Cache.DeleteRange(deleteKeys, min, max)
|
||||
|
||||
// delete from the WAL
|
||||
|
|
Loading…
Reference in New Issue