This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 5d1efef31da Remove the code check port is occupied, and resolve the
problem that can't rename file successfully. (#16893)
5d1efef31da is described below
commit 5d1efef31dab1ee7baab8dd5ba73b143a74c2709
Author: libo <[email protected]>
AuthorDate: Wed Dec 10 17:29:56 2025 +0800
Remove the code check port is occupied, and resolve the problem that can't
rename file successfully. (#16893)
---
.../test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java | 6 +++---
.../apache/iotdb/commons/schema/column/ColumnHeaderConstant.java | 2 +-
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java
b/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java
index bc043c79e8a..80aa854e66c 100644
---
a/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java
@@ -176,7 +176,7 @@ public class IoTDBConnectionsIT {
ResultSet resultSet =
statement.executeQuery(
- "SELECT * FROM connections WHERE data_node_id = '" + dataNodeId
+ "'");
+ "SELECT * FROM connections WHERE datanode_id = '" + dataNodeId +
"'");
if (!resultSet.next()) {
fail();
}
@@ -256,7 +256,7 @@ public class IoTDBConnectionsIT {
ResultSet resultSet =
statement.executeQuery(
- "SELECT COUNT(*) FROM connections WHERE data_node_id = '" +
closedDataNodeId + "'");
+ "SELECT COUNT(*) FROM connections WHERE datanode_id = '" +
closedDataNodeId + "'");
if (!resultSet.next()) {
fail();
}
@@ -306,7 +306,7 @@ public class IoTDBConnectionsIT {
ResultSet resultSet =
statement.executeQuery(
- "SELECT COUNT(*) FROM connections WHERE data_node_id = '" +
closedDataNodeId + "'");
+ "SELECT COUNT(*) FROM connections WHERE datanode_id = '" +
closedDataNodeId + "'");
if (!resultSet.next()) {
fail();
}
diff --git
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java
index 943bdeb9cba..67850d991cb 100644
---
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java
+++
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java
@@ -206,7 +206,7 @@ public class ColumnHeaderConstant {
public static final String STATEMENT = "Statement";
// column names for show idle connection
- public static final String DATANODE_ID = "data_node_id";
+ public static final String DATANODE_ID = "datanode_id";
public static final String USERID = "user_id";
public static final String SESSION_ID = "session_id";
public static final String USER_NAME = "user_name";