(iotdb) branch fixIT0408 updated: fix

[shuwenwei]

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

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


The following commit(s) were added to refs/heads/fixIT0408 by this push:
     new 9eaabf58531 fix
9eaabf58531 is described below

commit 9eaabf58531c814751871254c863e7df35b82f05
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 566654a4d72..0e7eefb3a41 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
@@ -70,6 +70,7 @@ import org.apache.iotdb.session.TableSessionBuilder;
 import org.apache.iotdb.session.pool.SessionPool;
 import org.apache.iotdb.session.pool.TableSessionPoolBuilder;
 
+import org.apache.thrift.TConfiguration;
 import org.apache.thrift.TException;
 import org.apache.thrift.transport.TSocket;
 import org.apache.thrift.transport.TTransportException;
@@ -1454,10 +1455,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()));
             }
           }
         }