(iotdb) 02/02: fix

[shuwenwei]

This is an automated email from the ASF dual-hosted git repository.

shuwenwei pushed a commit to branch fixIT0408-1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 83ac944046bcfc016487a7e93204bfbe2bd0db37
Author: shuwenwei <s13979062...@gmail.com>
AuthorDate: Wed Apr 8 17:07:25 2026 +0800

    fix
---
 .../java/org/apache/iotdb/it/env/cluster/env/AbstractEnv.java     | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AbstractEnv.java
 
b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AbstractEnv.java
index 3813a2890b1..07b7364d004 100644
--- 
a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AbstractEnv.java
+++ 
b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AbstractEnv.java
@@ -56,6 +56,7 @@ import org.apache.iotdb.rpc.TSStatusCode;
 import org.apache.iotdb.session.Session;
 import org.apache.iotdb.session.pool.SessionPool;
 
+import org.apache.thrift.TConfiguration;
 import org.apache.thrift.TException;
 import org.apache.thrift.transport.TSocket;
 import org.apache.thrift.transport.TTransportException;
@@ -1172,10 +1173,13 @@ public abstract class AbstractEnv implements BaseEnv {
             final String[] ipPort = 
nodeWrapper.getIpAndPortString().split(":");
             final String ip = ipPort[0];
             final int port = Integer.parseInt(ipPort[1]);
-            try (TSocket socket = new TSocket(ip, port)) {
+            try (TSocket socket = new TSocket(new TConfiguration(), ip, port, 
1000)) {
               socket.open();
             } catch (final TTransportException e) {
-              errorMessages.add(e.getMessage());
+              errorMessages.add(
+                  String.format(
+                      "DataNode %s is not reachable: %s",
+                      nodeWrapper.getIpAndPortString(), e.getMessage()));
             }
           }
         }