diff --git a/spring-cloud-kubernetes-integration-tests/spring-cloud-kubernetes-client-loadbalancer-it/src/test/java/org/springframework/cloud/kubernetes/client/loadbalancer/it/LoadBalancerIT.java b/spring-cloud-kubernetes-integration-tests/spring-cloud-kubernetes-client-loadbalancer-it/src/test/java/org/springframework/cloud/kubernetes/client/loadbalancer/it/LoadBalancerIT.java index abba8ce1..e7d01d9f 100644 --- a/spring-cloud-kubernetes-integration-tests/spring-cloud-kubernetes-client-loadbalancer-it/src/test/java/org/springframework/cloud/kubernetes/client/loadbalancer/it/LoadBalancerIT.java +++ b/spring-cloud-kubernetes-integration-tests/spring-cloud-kubernetes-client-loadbalancer-it/src/test/java/org/springframework/cloud/kubernetes/client/loadbalancer/it/LoadBalancerIT.java @@ -19,6 +19,7 @@ package org.springframework.cloud.kubernetes.client.loadbalancer.it; import java.io.IOException; import java.time.Duration; import java.util.Map; +import java.util.concurrent.TimeUnit; import io.kubernetes.client.openapi.ApiClient; import io.kubernetes.client.openapi.ApiException; @@ -142,7 +143,7 @@ public class LoadBalancerIT { }); // Sometimes the NGINX ingress takes a bit to catch up and realize the service is // available and we get a 503, we just need to wait a bit - await().timeout(Duration.ofSeconds(60)) + await().pollInterval(Duration.ofSeconds(1)).atMost(600, TimeUnit.SECONDS).ignoreExceptions() .until(() -> rest.getForEntity("http://localhost:80/loadbalancer-it/servicea", String.class) .getStatusCode().is2xxSuccessful()); Map result = rest.getForObject("http://localhost:80/loadbalancer-it/servicea", Map.class);