diff --git a/tools/functional-tester/etcd-tester/cluster.go b/tools/functional-tester/etcd-tester/cluster.go index f7aed5894..c1256080d 100644 --- a/tools/functional-tester/etcd-tester/cluster.go +++ b/tools/functional-tester/etcd-tester/cluster.go @@ -129,6 +129,9 @@ func (c *cluster) Bootstrap() error { } } + // TODO: Too intensive stressers can panic etcd member with + // 'out of memory' error. Put rate limits in server side. + stressN := 100 var stressers []Stresser if c.v2Only { for _, u := range clientURLs { @@ -136,7 +139,7 @@ func (c *cluster) Bootstrap() error { Endpoint: u, KeySize: c.stressKeySize, KeySuffixRange: c.stressKeySuffixRange, - N: 200, + N: stressN, } go s.Stress() stressers = append(stressers, s) @@ -147,7 +150,7 @@ func (c *cluster) Bootstrap() error { Endpoint: u, KeySize: c.stressKeySize, KeySuffixRange: c.stressKeySuffixRange, - N: 200, + N: stressN, } go s.Stress() stressers = append(stressers, s)