diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index f57616aed2..b4877b2ec9 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()