From 73389c7fda48543641f57a7c4611f844c1318673 Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Tue, 5 Mar 2024 14:29:51 +0800 Subject: [PATCH] fix --- .../src/test/java/org/apache/doris/flink/DorisTestBase.java | 6 +++++- 1 file changed, 5 insertions(+), 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 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));