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 e01c03b2fc5933f2ca2ac2fa0e193289e7fe078f Author: Weihao Li <[email protected]> AuthorDate: Thu Dec 11 19:45:26 2025 +0800 Fix the config 'query_cost_stat_window' cannot be hot loaded #16896 (cherry picked from commit 9abac5c2d76da6f1ade9ca3e958d194fd6a2acfc) --- .../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 6a1e8dbcccb..a039fc61774 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 @@ -2041,6 +2041,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(); }
