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 ca80232ae..46624572c 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,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));