From 8f8beeabb7deb04624c70444012ebc8ba59d990f Mon Sep 17 00:00:00 2001 From: Maciej Borsz Date: Wed, 20 Jan 2021 09:32:00 +0100 Subject: [PATCH] Print queue lengths on watch termination --- staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 de245c3a476..23ffc3ae31e 100644 --- a/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go +++ b/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go @@ -1258,7 +1258,7 @@ func (c *cacheWatcher) add(event *watchCacheEvent, timer *time.Timer) bool { // This means that we couldn't send event to that watcher. // Since we don't want to block on it infinitely, // we simply terminate it. - klog.V(1).Infof("Forcing %v watcher close due to unresponsiveness: %v", c.objectType.String(), c.identifier) + klog.V(1).Infof("Forcing %v watcher close due to unresponsiveness: %v. len(c.input) = %v, len(c.result) = %v", c.objectType.String(), c.identifier, len(c.input), len(c.result)) terminatedWatchersCounter.WithLabelValues(c.objectType.String()).Inc() c.forget() }