mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-29 06:27:05 +00:00
Merge pull request #32861 from wojtek-t/fix_density_test
Automatic merge from submit-queue Fix removing RCs in density test Ref #32571
This commit is contained in:
commit
d3235448ca
@ -35,6 +35,7 @@ import (
|
|||||||
"k8s.io/kubernetes/pkg/runtime"
|
"k8s.io/kubernetes/pkg/runtime"
|
||||||
"k8s.io/kubernetes/pkg/util/sets"
|
"k8s.io/kubernetes/pkg/util/sets"
|
||||||
utiluuid "k8s.io/kubernetes/pkg/util/uuid"
|
utiluuid "k8s.io/kubernetes/pkg/util/uuid"
|
||||||
|
"k8s.io/kubernetes/pkg/util/workqueue"
|
||||||
"k8s.io/kubernetes/pkg/watch"
|
"k8s.io/kubernetes/pkg/watch"
|
||||||
"k8s.io/kubernetes/test/e2e/framework"
|
"k8s.io/kubernetes/test/e2e/framework"
|
||||||
|
|
||||||
@ -662,10 +663,11 @@ var _ = framework.KubeDescribe("Density", func() {
|
|||||||
framework.LogSuspiciousLatency(startupLag, e2eLag, nodeCount, c)
|
framework.LogSuspiciousLatency(startupLag, e2eLag, nodeCount, c)
|
||||||
|
|
||||||
By("Removing additional replication controllers")
|
By("Removing additional replication controllers")
|
||||||
for i := 1; i <= nodeCount; i++ {
|
deleteRC := func(i int) {
|
||||||
name := additionalPodsPrefix + "-" + strconv.Itoa(i)
|
name := additionalPodsPrefix + "-" + strconv.Itoa(i+1)
|
||||||
c.ReplicationControllers(ns).Delete(name, nil)
|
framework.ExpectNoError(framework.DeleteRCAndWaitForGC(c, ns, name))
|
||||||
}
|
}
|
||||||
|
workqueue.Parallelize(16, nodeCount, deleteRC)
|
||||||
}
|
}
|
||||||
|
|
||||||
cleanupDensityTest(dConfig)
|
cleanupDensityTest(dConfig)
|
||||||
|
Loading…
Reference in New Issue
Block a user