From 370f9cf3b9f9898d2b22ea709e7441772f1039af Mon Sep 17 00:00:00 2001 From: tangcong Date: Mon, 26 Apr 2021 11:43:50 +0800 Subject: [PATCH] fix: failed to get failpoints from member --- tests/functional/tester/cluster.go | 2 -- tests/functional/tester/cluster_run.go | 4 ++++ 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/tests/functional/tester/cluster.go b/tests/functional/tester/cluster.go index befc07579..44cff91ea 100644 --- a/tests/functional/tester/cluster.go +++ b/tests/functional/tester/cluster.go @@ -113,8 +113,6 @@ func NewCluster(lg *zap.Logger, fpath string) (*Cluster, error) { } go clus.serveTesterServer() - clus.updateCases() - clus.rateLimiter = rate.NewLimiter( rate.Limit(int(clus.Tester.StressQPS)), int(clus.Tester.StressQPS), diff --git a/tests/functional/tester/cluster_run.go b/tests/functional/tester/cluster_run.go index 8529c514e..ac65ebca3 100644 --- a/tests/functional/tester/cluster_run.go +++ b/tests/functional/tester/cluster_run.go @@ -33,6 +33,10 @@ const compactQPS = 50000 func (clus *Cluster) Run() { defer printReport() + // updateCases must be executed after etcd is started, because the FAILPOINTS case + // needs to obtain all the failpoints from the etcd member. + clus.updateCases() + if err := fileutil.TouchDirAll(clus.Tester.DataDir); err != nil { clus.lg.Panic( "failed to create test data directory",