diff --git a/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go b/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go index 97e1e42f11b..0e462f800da 100644 --- a/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go +++ b/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go @@ -154,10 +154,10 @@ func (i *indexedWatchers) terminateAll(objectType reflect.Type, done func(*cache klog.Warningf("Terminating all watchers from cacher %v", objectType) } i.allWatchers.terminateAll(done) - for index, watchers := range i.valueWatchers { + for _, watchers := range i.valueWatchers { watchers.terminateAll(done) - delete(i.valueWatchers, index) } + i.valueWatchers = map[string]watchersMap{} } // As we don't need a high precision here, we keep all watchers timeout within a