(iotdb) branch master updated: Fix the config 'query_cost_stat_window' cannot be hot loaded #16896

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien 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 9abac5c2d76 Fix the config 'query_cost_stat_window' cannot be hot 
loaded #16896
9abac5c2d76 is described below

commit 9abac5c2d76da6f1ade9ca3e958d194fd6a2acfc
Author: Weihao Li <60659567+wei-hao...@users.noreply.github.com>
AuthorDate: Thu Dec 11 19:45:26 2025 +0800

    Fix the config 'query_cost_stat_window' cannot be hot loaded #16896
---
 .../it/query/recent/informationschema/IoTDBCurrentQueriesIT.java    | 2 +-
 .../src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java     | 6 ++++++
 .../iotdb/db/queryengine/plan/execution/config/ConfigExecution.java | 1 +
 3 files changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/informationschema/IoTDBCurrentQueriesIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/informationschema/IoTDBCurrentQueriesIT.java
index 66941ec784f..a68bd92b50b 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/informationschema/IoTDBCurrentQueriesIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/informationschema/IoTDBCurrentQueriesIT.java
@@ -64,7 +64,6 @@ public class IoTDBCurrentQueriesIT {
 
   @BeforeClass
   public static void setUp() throws Exception {
-    
EnvFactory.getEnv().getConfig().getDataNodeConfig().setQueryCostStatWindow(1);
     EnvFactory.getEnv().initClusterEnvironment();
     createUser("test", "test123123456");
   }
@@ -81,6 +80,7 @@ public class IoTDBCurrentQueriesIT {
           EnvFactory.getEnv().getConnection(ADMIN_NAME, ADMIN_PWD, 
BaseEnv.TABLE_SQL_DIALECT);
       Statement statement = connection.createStatement();
       statement.execute("USE information_schema");
+      statement.execute("set configuration \"query_cost_stat_window\"='1'");
 
       // 1. query current_queries table
       String sql = "SELECT * FROM current_queries";
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
index cfdb4c141b4..2fb7f7efdf0 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
@@ -2034,6 +2034,12 @@ public class IoTDBDescriptor {
               properties.getProperty(
                   "slow_query_threshold",
                   
ConfigurationFileUtils.getConfigurationDefaultValue("slow_query_threshold"))));
+      // update query_cost_stat_window
+      conf.setQueryCostStatWindow(
+          Integer.parseInt(
+              properties.getProperty(
+                  "query_cost_stat_window",
+                  
ConfigurationFileUtils.getConfigurationDefaultValue("query_cost_stat_window"))));
       // update select into operation max buffer size
       conf.setIntoOperationBufferSizeInByte(
           Long.parseLong(
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java
index 823a620820f..7868460f387 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java
@@ -354,6 +354,7 @@ public class ConfigExecution implements IQueryExecution {
     return context.getSession().getUserName();
   }
 
+  @Override
   public String getClientHostname() {
     return context.getCliHostname();
   }