github
/
k3s
mirror of https://github.com/k3s-io/k3s
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #14740 from piosz/autoscaling-e2e 

Fixed flakiness in autoscaling e2e with no scheduling pods
pull/6/head
Filip Grzadkowski 2015-09-29 17:27:41 +02:00
parent 0f8adc5d53 3a18af8ea8
commit 718c6f11e3
2 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/e2e/autoscaling.go
View File

@ -53,10 +53,10 @@ var _ = Describe("Autoscaling", func() {
}) })
It("[Skipped][Autoscaling Suite] should scale cluster size based on cpu utilization", func() { It("[Skipped][Autoscaling Suite] should scale cluster size based on cpu utilization", func() {
setUpAutoscaler("cpu/node_utilization", 0.5, nodeCount, nodeCount+1) setUpAutoscaler("cpu/node_utilization", 0.4, nodeCount, nodeCount+1)
// Consume 60% CPU // Consume 50% CPU
millicoresPerReplica := 600 millicoresPerReplica := 500
rc := NewStaticResourceConsumer("cpu-utilization", nodeCount*coresPerNode, millicoresPerReplica*nodeCount*coresPerNode, 0, int64(millicoresPerReplica), 100, f) rc := NewStaticResourceConsumer("cpu-utilization", nodeCount*coresPerNode, millicoresPerReplica*nodeCount*coresPerNode, 0, int64(millicoresPerReplica), 100, f)
expectNoError(waitForClusterSize(f.Client, nodeCount+1, 20*time.Minute)) expectNoError(waitForClusterSize(f.Client, nodeCount+1, 20*time.Minute))

18
test/e2e/autoscaling_utils.go
View File

@ -260,14 +260,16 @@ func runServiceAndRCForResourceConsumer(c *client.Client, ns, name string, repli
}) })
expectNoError(err) expectNoError(err)
config := RCConfig{ config := RCConfig{
Client: c, Client: c,
Image: image, Image: image,
Name: name, Name: name,
Namespace: ns, Namespace: ns,
Timeout: timeoutRC, Timeout: timeoutRC,
Replicas: replicas, Replicas: replicas,
CpuLimit: cpuLimitMillis, CpuRequest: cpuLimitMillis,
MemLimit: memLimitMb * 1024 * 1024, // MemLimit is in bytes CpuLimit: cpuLimitMillis,
MemRequest: memLimitMb * 1024 * 1024, // MemLimit is in bytes
MemLimit: memLimitMb * 1024 * 1024,
} }
expectNoError(RunRC(config)) expectNoError(RunRC(config))
// Make sure endpoints are propagated. // Make sure endpoints are propagated.