From e243883ea1cf0b7b15ef1147a6588f8ce05f829a Mon Sep 17 00:00:00 2001 From: Weihao Li <18110526956@163.com> Date: Thu, 11 Dec 2025 17:40:33 +0800 Subject: [PATCH 1/3] fix Signed-off-by: Weihao Li <18110526956@163.com> --- .../main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 ++++++ 1 file changed, 6 insertions(+) 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 cfdb4c141b41..2fb7f7efdf0a 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 synchronized void loadHotModifiedProps(TrimProperties properties) 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( From e233d73da02452c1521aa68806bbe5410ad94b00 Mon Sep 17 00:00:00 2001 From: Weihao Li <18110526956@163.com> Date: Thu, 11 Dec 2025 17:52:48 +0800 Subject: [PATCH 2/3] add IT Signed-off-by: Weihao Li <18110526956@163.com> --- .../query/recent/informationschema/IoTDBCurrentQueriesIT.java | 2 +- 1 file changed, 1 insertion(+), 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 66941ec784f8..a68bd92b50b4 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 void testCurrentQueries() { 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"; From 0c1a9b7f496630e44d87f108a75d4515d9ccda8a Mon Sep 17 00:00:00 2001 From: Weihao Li <18110526956@163.com> Date: Thu, 11 Dec 2025 17:56:08 +0800 Subject: [PATCH 3/3] add native Annotation Signed-off-by: Weihao Li <18110526956@163.com> --- .../db/queryengine/plan/execution/config/ConfigExecution.java | 1 + 1 file changed, 1 insertion(+) 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 823a620820fd..7868460f3870 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 String getUser() { return context.getSession().getUserName(); } + @Override public String getClientHostname() { return context.getCliHostname(); }