diff --git a/tools/functional-tester/etcd-tester/stresser.go b/tools/functional-tester/etcd-tester/stresser.go index 472f9df64..44dd6e39c 100644 --- a/tools/functional-tester/etcd-tester/stresser.go +++ b/tools/functional-tester/etcd-tester/stresser.go @@ -26,6 +26,7 @@ import ( clientV2 "github.com/coreos/etcd/client" "github.com/coreos/etcd/etcdserver" + "github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes" pb "github.com/coreos/etcd/etcdserver/etcdserverpb" "golang.org/x/net/context" "google.golang.org/grpc" @@ -112,6 +113,9 @@ func (s *stresser) Stress() error { case transport.ErrConnClosing.Desc: // server closed the transport (failure injected node) shouldContinue = true + case rpctypes.ErrNotCapable.Error(): + // capability check has not been done (in the beginning) + shouldContinue = true // default: // errors from stresser.Cancel method: