From b5abedc89756666eeb660b2782e0098fb9fdad44 Mon Sep 17 00:00:00 2001
From: Steve Yurong Su <rong@apache.org>
Date: Sun, 19 Jan 2025 02:46:51 +0800
Subject: [PATCH] Update IoTDBSyncClientManager.java

---
 .../connector/client/IoTDBSyncClientManager.java | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/client/IoTDBSyncClientManager.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/client/IoTDBSyncClientManager.java
index 468b37116cea..ce4900d73128 100644
--- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/client/IoTDBSyncClientManager.java
+++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/client/IoTDBSyncClientManager.java
@@ -132,7 +132,7 @@ public void checkClientStatusAndTryReconstructIfNecessary() {
     for (final Map.Entry<TEndPoint, String> entry : endPoint2HandshakeErrorMessage.entrySet()) {
       errorMessage
           .append(" (")
-          .append(" host: ")
+          .append("host: ")
           .append(entry.getKey().getIp())
           .append(", port: ")
           .append(entry.getKey().getPort())
@@ -183,17 +183,17 @@ private boolean initClientAndStatus(
               useSSL,
               trustStorePath,
               trustStorePwd));
+      return true;
     } catch (Exception e) {
       endPoint2HandshakeErrorMessage.put(endPoint, e.getMessage());
-      LOGGER.info(
-          String.format(
-              PipeConnectionException.CONNECTION_ERROR_FORMATTER,
-              endPoint.getIp(),
-              endPoint.getPort()),
+      LOGGER.warn(
+          "Failed to initialize client with target server ip: {}, port: {}, because {}",
+          endPoint.getIp(),
+          endPoint.getPort(),
+          e.getMessage(),
           e);
       return false;
     }
-    return true;
   }
 
   public void sendHandshakeReq(final Pair<IoTDBSyncClient, Boolean> clientAndStatus) {
@@ -217,7 +217,7 @@ public void sendHandshakeReq(final Pair<IoTDBSyncClient, Boolean> clientAndStatu
       // Receiver may be an old version, so we need to retry to handshake by
       // PipeTransferHandshakeV1Req.
       if (resp.getStatus().getCode() == TSStatusCode.PIPE_TYPE_ERROR.getStatusCode()) {
-        LOGGER.info(
+        LOGGER.warn(
             "Handshake error with target server ip: {}, port: {}, because: {}. "
                 + "Retry to handshake by PipeTransferHandshakeV1Req.",
             client.getIpAddress(),