diff --git a/pkg/registry/generic/etcd/etcd_test.go b/pkg/registry/generic/etcd/etcd_test.go index ef942e20a60..63b82f54219 100644 --- a/pkg/registry/generic/etcd/etcd_test.go +++ b/pkg/registry/generic/etcd/etcd_test.go @@ -536,6 +536,7 @@ func TestEtcdDeleteCollectionWithWatch(t *testing.T) { if err != nil { t.Fatalf("Unexpected error: %v", err) } + defer watcher.Stop() if _, err := registry.DeleteCollection(testContext, nil, &api.ListOptions{}); err != nil { t.Fatalf("Unexpected error: %v", err)