Merge pull request #105872 from wojtek-t/fix_delete_collection

Fix delete collection error channel size
2021-10-25 01:16:23 -07:00
parent 89dd275dde f609a8e0b5
commit 05a18a34b7
1 changed files with 1 additions and 1 deletions
--- 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{})