diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go index 9de5e4af3d8..515a8988c49 100644 --- a/pkg/kubelet/kubelet.go +++ b/pkg/kubelet/kubelet.go @@ -1632,7 +1632,10 @@ func (kl *Kubelet) syncLoop(updates <-chan PodUpdate, handler SyncHandler) { unsyncedPod := false podSyncTypes := make(map[types.UID]metrics.SyncPodType) select { - case u := <-updates: + case u, ok := <-updates: + if !ok { + return + } kl.podManager.UpdatePods(u, podSyncTypes) unsyncedPod = true case <-time.After(kl.resyncInterval):