domain: randomly trigger the DumpStatsDeltaToKV (#48692) (#48704)

close #48693
pingcap · Nov 20, 2023 · 5232881 · 5232881
1 parent 21db91b
commit 5232881
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/domain/domain.go b/domain/domain.go
@@ -2324,7 +2324,9 @@ func (do *Domain) updateStatsWorker(ctx sessionctx.Context, owner owner.Manager)
 	defer util.Recover(metrics.LabelDomain, "updateStatsWorker", nil, false)
 	logutil.BgLogger().Info("updateStatsWorker started.")
 	lease := do.statsLease
-	deltaUpdateTicker := time.NewTicker(20 * lease)
+	// We need to have different nodes trigger tasks at different times to avoid the herd effect.
+	randDuration := time.Duration(rand.Int63n(int64(time.Minute)))
+	deltaUpdateTicker := time.NewTicker(20*lease + randDuration)
 	gcStatsTicker := time.NewTicker(100 * lease)
 	dumpFeedbackTicker := time.NewTicker(200 * lease)
 	loadFeedbackTicker := time.NewTicker(5 * lease)