From 5e05ad23468e82004a900c5ac30e86e8e2af2603 Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Tue, 16 Jan 2024 10:39:01 +0800 Subject: [PATCH] update ci --- .../src/test/java/org/apache/doris/flink/DorisTestBase.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java index 2612fd7e8..c4f0bf0de 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/DorisTestBase.java @@ -28,6 +28,7 @@ import org.testcontainers.lifecycle.Startables; import org.testcontainers.utility.DockerLoggerFactory; +import java.net.InetAddress; import java.net.MalformedURLException; import java.net.URL; import java.net.URLClassLoader; @@ -112,7 +113,7 @@ public static GenericContainer createDorisContainer() { return container; } - protected static void initializeJdbcConnection() throws SQLException, MalformedURLException { + protected static void initializeJdbcConnection() throws Exception { URLClassLoader urlClassLoader = new URLClassLoader( new URL[] {new URL(DRIVER_JAR)}, DorisTestBase.class.getClassLoader()); @@ -142,7 +143,8 @@ private static boolean isBeReady(ResultSet rs, Duration duration) throws SQLExce return false; } - protected static void printClusterStatus() throws SQLException { + protected static void printClusterStatus() throws Exception { + LOG.info("Current machine IP: {}", InetAddress.getLocalHost()); try (Statement statement = connection.createStatement()) { ResultSet showFrontends = statement.executeQuery("show frontends"); LOG.info("Frontends status: {}", convertList(showFrontends));