github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-10 20:42:26 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #129775 from aojea/blame_allocator

Browse Source 
Blame allocator
This commit is contained in:
Kubernetes Prow Robot 2025-01-23 02:50:57 -08:00 committed by GitHub
commit 06331ac573
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
test/e2e/network/service.go
View File

@ -4118,6 +4118,22 @@ var _ = common.SIGDescribe("Services", func() {
// Request the same healthCheckNodePort as before, to test the user-requested allocation path
svc.Spec.HealthCheckNodePort = oldHealthCheckNodePort
})
if err != nil {
// We added a global static nodeport allocator to synchronize across tests and avoid other tests stealing the NodePort of this test and make it flake.
// Log the offending Service so we identify easily the problematic test.
// Dump all the IPs and look for the ones we want.
list, _ := cs.CoreV1().Services(metav1.NamespaceAll).List(ctx, metav1.ListOptions{})
for _, svc := range list.Items {
if svc.Spec.HealthCheckNodePort == oldHealthCheckNodePort {
framework.Failf("Service %#v stole NodePort from current test, please ensure that test is using the Static NodePort Allocator https://github.com/kubernetes/kubernetes/pull/127153 : %v", svc, err)
}
for _, port := range svc.Spec.Ports {
if port.NodePort == oldHealthCheckNodePort {
framework.Failf("Service %#v stole NodePort from current test, please ensure that test is using the Static NodePort Allocator https://github.com/kubernetes/kubernetes/pull/127153 : %v", svc, err)
}
}
}
}
framework.ExpectNoError(err, "updating ExternalTrafficPolicy and HealthCheckNodePort")
deadline = time.Now().Add(e2eservice.KubeProxyEndpointLagTimeout)