Skip to content

Commit 5d1efef

Browse files
authored
Remove the code check port is occupied, and resolve the problem that can't rename file successfully. (#16893)
1 parent 4a481f0 commit 5d1efef

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,7 @@ public void testSameDataNodeGetConnections() {
176176

177177
ResultSet resultSet =
178178
statement.executeQuery(
179-
"SELECT * FROM connections WHERE data_node_id = '" + dataNodeId + "'");
179+
"SELECT * FROM connections WHERE datanode_id = '" + dataNodeId + "'");
180180
if (!resultSet.next()) {
181181
fail();
182182
}
@@ -256,7 +256,7 @@ public void testClosedDataNodeGetConnections() throws Exception {
256256

257257
ResultSet resultSet =
258258
statement.executeQuery(
259-
"SELECT COUNT(*) FROM connections WHERE data_node_id = '" + closedDataNodeId + "'");
259+
"SELECT COUNT(*) FROM connections WHERE datanode_id = '" + closedDataNodeId + "'");
260260
if (!resultSet.next()) {
261261
fail();
262262
}
@@ -306,7 +306,7 @@ public void testClosedDataNodeGetConnections() throws Exception {
306306

307307
ResultSet resultSet =
308308
statement.executeQuery(
309-
"SELECT COUNT(*) FROM connections WHERE data_node_id = '" + closedDataNodeId + "'");
309+
"SELECT COUNT(*) FROM connections WHERE datanode_id = '" + closedDataNodeId + "'");
310310
if (!resultSet.next()) {
311311
fail();
312312
}

iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/column/ColumnHeaderConstant.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ private ColumnHeaderConstant() {
206206
public static final String STATEMENT = "Statement";
207207

208208
// column names for show idle connection
209-
public static final String DATANODE_ID = "data_node_id";
209+
public static final String DATANODE_ID = "datanode_id";
210210
public static final String USERID = "user_id";
211211
public static final String SESSION_ID = "session_id";
212212
public static final String USER_NAME = "user_name";

0 commit comments

Comments
 (0)