diff --git a/etcd/etcd_functional_test.go b/etcd/etcd_functional_test.go index 948fae5a1..f6b6e5d34 100644 --- a/etcd/etcd_functional_test.go +++ b/etcd/etcd_functional_test.go @@ -173,6 +173,8 @@ func TestClusterConfigReload(t *testing.T) { } lead, _ = waitLeader(es) + // wait for msgAppResp to commit all entries + time.Sleep(2 * defaultHeartbeat * es[lead].tickDuration) if g := es[lead].p.clusterConfig(); !reflect.DeepEqual(g, conf) { t.Errorf("#%d: clusterConfig = %+v, want %+v", i, g, conf) }