You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by sh...@apache.org on 2026/04/08 09:07:36 UTC
(iotdb) branch fixIT0408 updated: fix
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 <s1...@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()));
}
}
}