From e2e1d9e943e11d896ea2bc603837f59adc0bd036 Mon Sep 17 00:00:00 2001 From: Dawn Chen Date: Tue, 24 Mar 2015 13:13:25 -0700 Subject: [PATCH] Fix a bug of running node selector predicate on kubelet introduced by #5715. part of #5207, and fixed #5810 --- pkg/kubelet/kubelet.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index 328c85be6ba..ff4ce898cd0 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -166,7 +166,7 @@ func NewMainKubelet( } serviceLister := &cache.StoreToServiceLister{serviceStore} - serviceStore = cache.NewStore(cache.MetaNamespaceKeyFunc) + nodeStore := cache.NewStore(cache.MetaNamespaceKeyFunc) if kubeClient != nil { // TODO: cache.NewListWatchFromClient is limited as it takes a client implementation rather // than an interface. There is no way to construct a list+watcher using resource name. @@ -183,9 +183,9 @@ func NewMainKubelet( labels.Everything(), fields.Everything(), resourceVersion) }, } - cache.NewReflector(listWatch, &api.Service{}, serviceStore, 0).Run() + cache.NewReflector(listWatch, &api.Node{}, nodeStore, 0).Run() } - nodeLister := &cache.StoreToNodeLister{serviceStore} + nodeLister := &cache.StoreToNodeLister{nodeStore} containerGC, err := newContainerGC(dockerClient, containerGCPolicy) if err != nil {