v3rpc: add jitter to progress notification

etcdserver/api/v3rpc/watch.go

@@ -17,6 +17,7 @@ package v3rpc
 import (
 	"context"
 	"io"
+	"math/rand"
 	"sync"
 	"time"
 
@@ -56,9 +57,14 @@ var (
 )
 
 func GetProgressReportInterval() time.Duration {
+	// add rand(1/10*progressReportInterval) as jitter so that etcdserver will not
+	// send progress notifications to watchers around the same time even when watchers
+	// are created around the same time (which is common when a client restarts itself).
+	jitter := time.Duration(rand.Int63n(int64(progressReportInterval) / 10))
+
 	progressReportIntervalMu.RLock()
 	defer progressReportIntervalMu.RUnlock()
-	return progressReportInterval
+	return progressReportInterval + jitter
 }
 
 func SetProgressReportInterval(newTimeout time.Duration) {