diff --git a/etcdserver/server.go b/etcdserver/server.go index aa830a603..3466355f0 100644 --- a/etcdserver/server.go +++ b/etcdserver/server.go @@ -801,14 +801,19 @@ func (s *EtcdServer) transferLeadership(ctx context.Context, lead, transferee ui // TODO: drain all requests, or drop all messages to the old leader - plog.Infof("%s finished leadership transfer from %s to to %s (took %v)", s.ID(), types.ID(lead), types.ID(transferee), time.Since(now)) + plog.Infof("%s finished leadership transfer from %s to %s (took %v)", s.ID(), types.ID(lead), types.ID(transferee), time.Since(now)) return nil } // TransferLeadership transfers the leader to the chosen transferee. func (s *EtcdServer) TransferLeadership() error { - if !s.isMultiNode() || !s.isLeader() { - plog.Printf("skipping leader transfer since multi-node %v or is-leader %v", s.isMultiNode(), s.isLeader()) + if !s.isLeader() { + plog.Printf("skipped leadership transfer for stopping non-leader member") + return nil + } + + if !s.isMultiNode() { + plog.Printf("skipped leadership transfer for single member cluster") return nil }