Skip to content

OCPBUGS-78470: e2e: fixed flaky test_id:32646 CPU load balancing on cgroupv1 #1457

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
openshift-merge-bot merged 1 commit into from
Mar 13, 2026
Merged

OCPBUGS-78470: e2e: fixed flaky test_id:32646 CPU load balancing on cgroupv1 #1457

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 9 additions & 3 deletions test/e2e/performanceprofile/functests/1_performance/cpu_management.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -909,15 +909,21 @@ var _ = Describe("[rfe_id:27363][performance] CPU Management", Ordered, func() {
Expect(err).ToNot(HaveOccurred(), "unable to fetch cpus used by testpod")
podCpus, err := cpuset.Parse(output)
Expect(err).ToNot(HaveOccurred(), "unable to parse cpuset used by pod")

// Wait for kubelet's CPU Manager to reconcile cpusets before checking
// scheduling domains (since on cgroupv1 all overlapping cgroups must be
// updated). Without this sleep the check can flake.
time.Sleep(1 * time.Minute)

By("Getting the CPU scheduling flags")
// After the testpod is started get the schedstat and check for cpus
// not participating in scheduling domains
// not participating in scheduling domains.
checkSchedulingDomains(targetNode, podCpus, func(cpuIDs cpuset.CPUSet) error {
if !podCpus.IsSubsetOf(cpuIDs) {
return fmt.Errorf("pod CPUs NOT entirely part of cpus with load balance disabled: %v vs %v", podCpus, cpuIDs)
}
return nil
}, 2*time.Minute, 5*time.Second, "checking scheduling domains with pod running")
}, 5*time.Minute, 5*time.Second, "checking scheduling domains with pod running")
})

It("[test_id:73382]cpuset.cpus.exclusive of kubepods.slice should be updated", func() {
Expand Down Expand Up @@ -1510,7 +1516,7 @@ func checkSchedulingDomains(workerRTNode *corev1.Node, podCpus cpuset.CPUSet, te
}
cpuIDs := cpuset.New(cpuIDList...)
return testFunc(cpuIDs)
}).WithTimeout(2*time.Minute).WithPolling(5*time.Second).ShouldNot(HaveOccurred(), errMsg)
}).WithTimeout(timeout).WithPolling(polling).ShouldNot(HaveOccurred(), errMsg)
}

// busyCpuImageEnv return busycpus image used for crio quota annotations test
Expand Down