You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2025/12/10 11:42:48 UTC
(iotdb) 10/12: Remove the code check port is occupied, and resolve the problem that can't rename file successfully. (#16893)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch ty/object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1a51743f80d582ecd88fd2953cb4c7bfa1001c72
Author: libo <ze...@163.com>
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)
(cherry picked from commit 5d1efef31dab1ee7baab8dd5ba73b143a74c2709)
---
.../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";