diff --git a/staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go b/staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go index 78cf9231a70..697fb6a35c2 100644 --- a/staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go +++ b/staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go @@ -1126,7 +1126,7 @@ func (e *Store) DeleteCollection(ctx context.Context, deleteValidation rest.Vali } wg := sync.WaitGroup{} toProcess := make(chan int, 2*workersNumber) - errs := make(chan error, workersNumber) + errs := make(chan error, workersNumber+1) workersExited := make(chan struct{}) distributorExited := make(chan struct{})