fix

JNSimba · Mar 5, 2024 · 7bb21d9 · 7bb21d9
1 parent 73389c7
commit 7bb21d9
Showing 1 changed file with 4 additions and 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
@@ -144,10 +144,12 @@ private static boolean isBeReady(ResultSet rs, Duration duration) throws SQLExce
 
     protected static void printClusterStatus() throws Exception {
         LOG.info(
-                "{} {} Current machine IP: {}",
+                "{} {} Current machine IP: {} {} {}",
                 Thread.currentThread().getId(),
                 Thread.currentThread().getName(),
-                InetAddress.getLocalHost());
+                InetAddress.getLocalHost(),
+                connection.isClosed(),
+                connection.isValid(1000));
         try (Statement statement = connection.createStatement()) {
             ResultSet showFrontends = statement.executeQuery("show frontends");
             LOG.info("Frontends status: {}", convertList(showFrontends));