From 7dddec679957199abcacaa8a4dbf654ca8abc02c Mon Sep 17 00:00:00 2001 From: "Dr. Stefan Schimanski" Date: Wed, 14 Oct 2015 15:38:44 +0200 Subject: [PATCH] Switch to empty ADD PodUpdate for PodConfigNotificationIncremental mode --- pkg/kubelet/config/config.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/pkg/kubelet/config/config.go b/pkg/kubelet/config/config.go index efe86e2eebb..f486124d0e2 100644 --- a/pkg/kubelet/config/config.go +++ b/pkg/kubelet/config/config.go @@ -159,13 +159,10 @@ func (s *podStorage) Merge(source string, change interface{}) error { // deliver update notifications switch s.mode { case PodConfigNotificationIncremental: - if firstSet { - s.updates <- kubetypes.PodUpdate{Pods: s.MergedState().([]*api.Pod), Op: kubetypes.SET, Source: source} - } if len(deletes.Pods) > 0 { s.updates <- *deletes } - if len(adds.Pods) > 0 { + if len(adds.Pods) > 0 || firstSet { s.updates <- *adds } if len(updates.Pods) > 0 {