From ad8935be3ba4499e68f5ae726a38e14e368b43c6 Mon Sep 17 00:00:00 2001 From: jcechace Date: Fri, 21 Oct 2022 11:48:23 +0200 Subject: [PATCH] DBZ-5753 ingres connection on Azure --- .../tools/databases/AbstractOcpDatabaseController.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/debezium-testing/debezium-testing-system/src/main/java/io/debezium/testing/system/tools/databases/AbstractOcpDatabaseController.java b/debezium-testing/debezium-testing-system/src/main/java/io/debezium/testing/system/tools/databases/AbstractOcpDatabaseController.java index ab9e1331d..1749dd973 100644 --- a/debezium-testing/debezium-testing-system/src/main/java/io/debezium/testing/system/tools/databases/AbstractOcpDatabaseController.java +++ b/debezium-testing/debezium-testing-system/src/main/java/io/debezium/testing/system/tools/databases/AbstractOcpDatabaseController.java @@ -12,11 +12,13 @@ import static org.awaitility.Awaitility.await; import java.util.List; +import java.util.Objects; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import io.debezium.testing.system.tools.OpenShiftUtils; +import io.fabric8.kubernetes.api.model.LoadBalancerIngress; import io.fabric8.kubernetes.api.model.Service; import io.fabric8.kubernetes.api.model.apps.Deployment; import io.fabric8.openshift.client.OpenShiftClient; @@ -103,8 +105,11 @@ public String getPublicDatabaseHostname() { return getDatabaseHostname(); } awaitIngress(); - return getLoadBalancedService().getStatus().getLoadBalancer() - .getIngress().get(0).getHostname(); + + LoadBalancerIngress ingres = getLoadBalancedService().getStatus().getLoadBalancer().getIngress().get(0); + String address = (ingres.getHostname() != null) ? ingres.getHostname() : ingres.getIp(); + + return Objects.requireNonNull(address, "Unable to retrieve hostname or ip for service ingres"); } @Override