From 48d757b6bb5a46ef8daf48fe57cc88bee4f80262 Mon Sep 17 00:00:00 2001 From: pytimer Date: Tue, 11 Dec 2018 10:03:22 +0800 Subject: [PATCH] kubeadm: fixed etcd sync endpoints --- cmd/kubeadm/app/util/etcd/etcd.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cmd/kubeadm/app/util/etcd/etcd.go b/cmd/kubeadm/app/util/etcd/etcd.go index bc93c20597..c1c745f024 100644 --- a/cmd/kubeadm/app/util/etcd/etcd.go +++ b/cmd/kubeadm/app/util/etcd/etcd.go @@ -190,12 +190,13 @@ func NewFromCluster(client clientset.Interface, certificatesDir string) (*Client if err != nil { return nil, errors.Wrap(err, "error syncing endpoints with etc") } + klog.V(1).Infof("update etcd endpoints: %s", strings.Join(etcdClient.Endpoints, ",")) return etcdClient, nil } // Sync synchronizes client's endpoints with the known endpoints from the etcd membership. -func (c Client) Sync() error { +func (c *Client) Sync() error { cli, err := clientv3.New(clientv3.Config{ Endpoints: c.Endpoints, DialTimeout: 20 * time.Second,