core: clean some remain code about deviation filter. (#5329)

close #5328

Signed-off-by: bufferflies <[email protected]>

server/core/store_stats.go

@@ -15,8 +15,6 @@
 package core
 
 import (
-	"math"
-
 	"github.com/pingcap/kvproto/pkg/pdpb"
 	"github.com/tikv/pd/pkg/movingaverage"
 	"github.com/tikv/pd/pkg/syncutil"
@@ -28,20 +26,12 @@ type storeStats struct {
 
 	// avgAvailable is used to make available smooth, aka no sudden changes.
 	avgAvailable *movingaverage.HMA
-	// Following two fields are used to trace the deviation when available
-	// records' deviation range to make scheduling able to converge.
-	// Here `MaxFilter` is used to make the scheduling more conservative, and
-	// `HMA` is used to make it smooth.
-	maxAvailableDeviation    *movingaverage.MaxFilter
-	avgMaxAvailableDeviation *movingaverage.HMA
 }
 
 func newStoreStats() *storeStats {
 	return &storeStats{
-		rawStats:                 &pdpb.StoreStats{},
-		avgAvailable:             movingaverage.NewHMA(60),        // take 10 minutes sample under 10s heartbeat rate
-		maxAvailableDeviation:    movingaverage.NewMaxFilter(120), // take 20 minutes sample under 10s heartbeat rate
-		avgMaxAvailableDeviation: movingaverage.NewHMA(60),        // take 10 minutes sample under 10s heartbeat rate
+		rawStats:     &pdpb.StoreStats{},
+		avgAvailable: movingaverage.NewHMA(60), // take 10 minutes sample under 10s heartbeat rate
 	}
 }
 
@@ -53,11 +43,7 @@ func (ss *storeStats) updateRawStats(rawStats *pdpb.StoreStats) {
 	if ss.avgAvailable == nil {
 		return
 	}
-
 	ss.avgAvailable.Add(float64(rawStats.GetAvailable()))
-	deviation := math.Abs(float64(rawStats.GetAvailable()) - ss.avgAvailable.Get())
-	ss.maxAvailableDeviation.Add(deviation)
-	ss.avgMaxAvailableDeviation.Add(ss.maxAvailableDeviation.Get())
 }
 
 // GetStoreStats returns the statistics information of the store.
@@ -157,16 +143,6 @@ func (ss *storeStats) GetAvgAvailable() uint64 {
 	return climp0(ss.avgAvailable.Get())
 }
 
-// GetAvailableDeviation returns approximate magnitude of available in the recent period.
-func (ss *storeStats) GetAvailableDeviation() uint64 {
-	ss.mu.RLock()
-	defer ss.mu.RUnlock()
-	if ss.avgMaxAvailableDeviation == nil {
-		return 0
-	}
-	return climp0(ss.avgMaxAvailableDeviation.Get())
-}
-
 func climp0(v float64) uint64 {
 	if v <= 0 {
 		return 0

server/core/store_stats_test.go

@@ -36,7 +36,6 @@ func TestStoreStats(t *testing.T) {
 	re.Equal(uint64(50*units.GiB), store.GetUsedSize())
 	re.Equal(uint64(150*units.GiB), store.GetAvailable())
 	re.Equal(uint64(150*units.GiB), store.GetAvgAvailable())
-	re.Equal(uint64(0), store.GetAvailableDeviation())
 
 	store = store.Clone(SetStoreStats(&pdpb.StoreStats{
 		Capacity:  uint64(200 * units.GiB),
@@ -47,6 +46,4 @@ func TestStoreStats(t *testing.T) {
 	re.Equal(uint64(160*units.GiB), store.GetAvailable())
 	re.Greater(store.GetAvgAvailable(), uint64(150*units.GiB))
 	re.Less(store.GetAvgAvailable(), uint64(160*units.GiB))
-	re.Greater(store.GetAvailableDeviation(), uint64(0))
-	re.Less(store.GetAvailableDeviation(), uint64(10*units.GiB))
 }

server/statistics/store_collection.go

@@ -119,8 +119,6 @@ func (s *storeStatistics) Observe(store *core.StoreInfo, stats *StoresStats) {
 	storeStatusGauge.WithLabelValues(storeAddress, id, "store_available").Set(float64(store.GetAvailable()))
 	storeStatusGauge.WithLabelValues(storeAddress, id, "store_used").Set(float64(store.GetUsedSize()))
 	storeStatusGauge.WithLabelValues(storeAddress, id, "store_capacity").Set(float64(store.GetCapacity()))
-	storeStatusGauge.WithLabelValues(storeAddress, id, "store_available_avg").Set(float64(store.GetAvgAvailable()))
-	storeStatusGauge.WithLabelValues(storeAddress, id, "store_available_deviation").Set(float64(store.GetAvailableDeviation()))
 
 	// Store flows.
 	storeFlowStats := stats.GetRollingStoreStats(store.GetID())