fix

JNSimba · Mar 5, 2024 · 73389c7 · 73389c7
1 parent 431693b
commit 73389c7
Showing 1 changed file with 5 additions 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,11 @@ private static boolean isBeReady(ResultSet rs, Duration duration) throws SQLExce
     }
 
     protected static void printClusterStatus() throws Exception {
-        LOG.info("{} {} Current machine IP: {}", Thread.currentThread().getId(), Thread.currentThread().getName(), 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));