From 2d0fe164636bd0f6cbc85157dc99e9ba183e375d Mon Sep 17 00:00:00 2001 From: Wojciech Tyczynski Date: Fri, 27 Jan 2017 15:01:55 +0100 Subject: [PATCH] Minor cleanup in getting from apiserver cache in kubelet --- pkg/kubelet/BUILD | 1 + pkg/kubelet/kubelet_node_status.go | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/kubelet/BUILD b/pkg/kubelet/BUILD index 3bb6cb72726..41f3e7bbb29 100644 --- a/pkg/kubelet/BUILD +++ b/pkg/kubelet/BUILD @@ -80,6 +80,7 @@ go_library( "//pkg/kubelet/status:go_default_library", "//pkg/kubelet/sysctl:go_default_library", "//pkg/kubelet/types:go_default_library", + "//pkg/kubelet/util:go_default_library", "//pkg/kubelet/util/format:go_default_library", "//pkg/kubelet/util/queue:go_default_library", "//pkg/kubelet/util/sliceutils:go_default_library", diff --git a/pkg/kubelet/kubelet_node_status.go b/pkg/kubelet/kubelet_node_status.go index 062355b21be..65e92e4784d 100644 --- a/pkg/kubelet/kubelet_node_status.go +++ b/pkg/kubelet/kubelet_node_status.go @@ -37,6 +37,7 @@ import ( "k8s.io/kubernetes/pkg/cloudprovider" "k8s.io/kubernetes/pkg/kubelet/cadvisor" "k8s.io/kubernetes/pkg/kubelet/events" + "k8s.io/kubernetes/pkg/kubelet/util" "k8s.io/kubernetes/pkg/kubelet/util/sliceutils" nodeutil "k8s.io/kubernetes/pkg/util/node" "k8s.io/kubernetes/pkg/version" @@ -349,7 +350,7 @@ func (kl *Kubelet) tryUpdateNodeStatus(tryNumber int) error { // If it result in a conflict, all retries are served directly from etcd. opts := metav1.GetOptions{} if tryNumber == 0 { - opts.ResourceVersion = "0" + util.FromApiserverCache(&opts) } node, err := kl.kubeClient.Core().Nodes().Get(string(kl.nodeName), opts) if err != nil {