From 5da52558e62bd3353f6736b0ccbb79245a26a1ba Mon Sep 17 00:00:00 2001 From: Wojciech Tyczynski Date: Mon, 14 Sep 2015 15:05:17 +0200 Subject: [PATCH] Fix watch with RV=0 in Kubelet. --- pkg/kubelet/kubelet.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index 569769c1e09..b8e4327c219 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -208,11 +208,7 @@ func NewMainKubelet( fieldSelector := fields.Set{client.ObjectNameField: nodeName}.AsSelector() listWatch := &cache.ListWatch{ ListFunc: func() (runtime.Object, error) { - obj, err := kubeClient.Nodes().Get(nodeName) - if err != nil { - return nil, err - } - return &api.NodeList{Items: []api.Node{*obj}}, nil + return kubeClient.Nodes().List(labels.Everything(), fieldSelector) }, WatchFunc: func(resourceVersion string) (watch.Interface, error) { return kubeClient.Nodes().Watch(labels.Everything(), fieldSelector, resourceVersion)