fix

JNSimba · Mar 5, 2024 · 431693b · 431693b
1 parent 908bf96
commit 431693b
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -143,7 +143,7 @@ private static boolean isBeReady(ResultSet rs, Duration duration) throws SQLExce
     }
 
     protected static void printClusterStatus() throws Exception {
-        LOG.info("Current machine IP: {}", InetAddress.getLocalHost());
+        LOG.info("{} {} Current machine IP: {}", Thread.currentThread().getId(), Thread.currentThread().getName(), InetAddress.getLocalHost());
         try (Statement statement = connection.createStatement()) {
             ResultSet showFrontends = statement.executeQuery("show frontends");
             LOG.info("Frontends status: {}", convertList(showFrontends));