diff --git a/pkg/grpc-etcdv3/getcdv3/pool.go b/pkg/grpc-etcdv3/getcdv3/pool.go index 943f4bd3f..437795949 100644 --- a/pkg/grpc-etcdv3/getcdv3/pool.go +++ b/pkg/grpc-etcdv3/getcdv3/pool.go @@ -171,11 +171,7 @@ func (p *Pool) Get(ctx context.Context) (*ClientConn, error) { if wrapper.ClientConn == nil { wrapper.ClientConn, err = p.factory(ctx) if err != nil { - // If there was an error, we want to put back a placeholder - // client in the channel - clients <- ClientConn{ - pool: p, - } + return nil, err } // This is a new connection, reset its initiated time wrapper.timeInitiated = time.Now()