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 bc043c79e8a6..80aa854e66cc 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 void testSameDataNodeGetConnections() {
 
       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 void testClosedDataNodeGetConnections() throws Exception {
 
       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 void testClosedDataNodeGetConnections() throws Exception {
 
       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 943bdeb9cba4..67850d991cb6 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 @@ private 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";