From 431693bb9ccaaa999c0239e6327ce2615c40b6ad Mon Sep 17 00:00:00 2001
From: wudi <676366545@qq.com>
Date: Tue, 5 Mar 2024 14:25:11 +0800
Subject: [PATCH] fix

---
 .../src/test/java/org/apache/doris/flink/DorisTestBase.java     | 2 +-
 1 file changed, 1 insertion(+), 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
index 7b19f74f8..ca80232ae 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
@@ -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));