From 7bb21d9a30b5ccdf3e983adac28ed876f871f6f6 Mon Sep 17 00:00:00 2001
From: wudi <676366545@qq.com>
Date: Tue, 5 Mar 2024 14:59:55 +0800
Subject: [PATCH] fix

---
 .../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 46624572c..31ff2b124 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
@@ -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));