From 6c33ca13e9e8d52e39af0fff532792e3111b7112 Mon Sep 17 00:00:00 2001 From: Avesh Agarwal Date: Wed, 18 Jul 2018 15:15:03 -0400 Subject: [PATCH] Start cloudResourceSyncsManager before getNodeAnyWay (initializeModules) so that kubelet does not get stuck in retriving node addresses from a cloudprovider. --- pkg/kubelet/kubelet.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index f57616aed2b..b4877b2ec96 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -1321,6 +1321,11 @@ func (kl *Kubelet) Run(updates <-chan kubetypes.PodUpdate) { glog.Warning("No api server defined - no node status update will be sent.") } + // Start the cloud provider sync manager + if kl.cloudResourceSyncManager != nil { + go kl.cloudResourceSyncManager.Run(wait.NeverStop) + } + if err := kl.initializeModules(); err != nil { kl.recorder.Eventf(kl.nodeRef, v1.EventTypeWarning, events.KubeletSetupFailed, err.Error()) glog.Fatal(err) @@ -1344,11 +1349,6 @@ func (kl *Kubelet) Run(updates <-chan kubetypes.PodUpdate) { // handled by pod workers). go wait.Until(kl.podKiller, 1*time.Second, wait.NeverStop) - // Start the cloud provider sync manager - if kl.cloudResourceSyncManager != nil { - go kl.cloudResourceSyncManager.Run(wait.NeverStop) - } - // Start component sync loops. kl.statusManager.Start() kl.probeManager.Start()