diff --git a/pkg/utils/etcdutil/etcdutil.go b/pkg/utils/etcdutil/etcdutil.go index 91c315fd240d..af437f734729 100644 --- a/pkg/utils/etcdutil/etcdutil.go +++ b/pkg/utils/etcdutil/etcdutil.go @@ -165,7 +165,7 @@ func EtcdKVGet(c *clientv3.Client, key string, opts ...clientv3.OpOption) (*clie func IsHealthy(ctx context.Context, client *clientv3.Client) bool { timeout := DefaultRequestTimeout failpoint.Inject("fastTick", func() { - timeout = 10 * time.Millisecond + timeout = 20 * time.Millisecond }) ctx, cancel := context.WithTimeout(clientv3.WithRequireLeader(ctx), timeout) defer cancel() @@ -265,7 +265,7 @@ func CreateEtcdClient(tlsConfig *tls.Config, acURLs []url.URL, sourceOpt ...stri tickerInterval := defaultDialKeepAliveTime failpoint.Inject("fastTick", func() { - tickerInterval = 10 * time.Millisecond + tickerInterval = 20 * time.Millisecond }) failpoint.Inject("closeTick", func() { failpoint.Return(client, err) diff --git a/pkg/utils/etcdutil/etcdutil_test.go b/pkg/utils/etcdutil/etcdutil_test.go index d330165cf290..479548902115 100644 --- a/pkg/utils/etcdutil/etcdutil_test.go +++ b/pkg/utils/etcdutil/etcdutil_test.go @@ -661,7 +661,7 @@ func (suite *loopWatcherTestSuite) TestWatcherBreak() { func([]*clientv3.Event) error { return nil }, false, /* withPrefix */ ) - watcher.watchChangeRetryInterval = 100 * time.Millisecond + watcher.watchChangeRetryInterval = 20 * time.Millisecond watcher.StartWatchLoop() err := watcher.WaitLoad() re.NoError(err)