recheck

Signed-off-by: husharp <jinhao.hu@pingcap.com>
tikv · Jan 18, 2024 · de02922 · de02922
1 parent 3607af1
commit de02922
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pkg/utils/etcdutil/etcdutil.go b/pkg/utils/etcdutil/etcdutil.go
@@ -365,7 +365,7 @@ func (checker *HealthyChecker) inspector(ctx context.Context) {
 			for _, ep := range lastEps {
 				// add new trend
 				if _, ok := checker.allRecordUrls[ep]; !ok {
-					checker.allRecordUrls[ep] = trend.NewTrend(fmt.Sprintf("%s-%s", checker.name, ep), 20)
+					checker.allRecordUrls[ep] = trend.NewTrend(fmt.Sprintf("%s-%s", checker.name, ep), 20*time.Second)
 					etcdAsyncVals[ep] = trend.NewAsyncFromEtcd()
 				}
 			}

diff --git a/server/trend/trend.go b/server/trend/trend.go
@@ -166,7 +166,7 @@ func laLbRateSimple(laAvg, lbAvg, marginError float64) float64 {
 }
 
 // TODO: unSensitiveCause reduce influence of spike
-const unSensitiveCause = 2.0
+const unSensitiveCause = 3.0
 
 // A*(A-B)^2 / Sqrt(B) = x
 func laLbRate(laAvg float64, lbAvg float64, marginError float64) float64 {

diff --git a/server/trend/trend_test.go b/server/trend/trend_test.go
@@ -118,7 +118,7 @@ func TestTrendGetAsyncMock(t *testing.T) {
 		now = now.Add(time.Millisecond * 100)
 		time.Sleep(time.Millisecond * 100)
 		res := float64(rand.Intn(8)+1) * 0.001
-		trend.Record(1, res+4, now)
+		trend.Record(1, res+10, now)
 	}
 
 	log.Info("--------------------- normal ---------------------")