This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 31a23baa37 [fix](planner) Add default execution interval time for
stats framework (#13044)
31a23baa37 is described below
commit 31a23baa37809d5b795a58c2fe8ddbe17fbdd761
Author: Kikyou1997 <[email protected]>
AuthorDate: Thu Sep 29 22:40:27 2022 +0800
[fix](planner) Add default execution interval time for stats framework
(#13044)
Set a default execution interval for stats collection related threads.
---
fe/fe-core/src/main/java/org/apache/doris/common/Config.java | 6 ++++++
.../java/org/apache/doris/statistics/StatisticsJobScheduler.java | 3 ++-
.../java/org/apache/doris/statistics/StatisticsTaskScheduler.java | 3 ++-
3 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
index 1ec86615d9..2c1c57c72e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
@@ -1785,4 +1785,10 @@ public class Config extends ConfigBase {
*/
@ConfField(mutable = true, masterOnly = true)
public static int be_exec_version = max_be_exec_version;
+
+ @ConfField(mutable = false)
+ public static int statistic_job_scheduler_execution_interval_ms = 60 * 60
* 1000;
+
+ @ConfField(mutable = false)
+ public static int statistic_task_scheduler_execution_interval_ms = 60 * 60
* 1000;
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsJobScheduler.java
b/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsJobScheduler.java
index bed7db7b86..006076b4a0 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsJobScheduler.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsJobScheduler.java
@@ -78,7 +78,8 @@ public class StatisticsJobScheduler extends MasterDaemon {
= Queues.newLinkedBlockingQueue(Config.cbo_max_statistics_job_num);
public StatisticsJobScheduler() {
- super("Statistics job scheduler", 0);
+ super("Statistics job scheduler",
+ Config.statistic_job_scheduler_execution_interval_ms);
}
@Override
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsTaskScheduler.java
b/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsTaskScheduler.java
index b46a4106b8..6bac7d9e79 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsTaskScheduler.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/statistics/StatisticsTaskScheduler.java
@@ -52,7 +52,8 @@ public class StatisticsTaskScheduler extends MasterDaemon {
private final Queue<StatisticsTask> queue =
Queues.newLinkedBlockingQueue();
public StatisticsTaskScheduler() {
- super("Statistics task scheduler", 0);
+ super("Statistics task scheduler",
+ Config.statistic_task_scheduler_execution_interval_ms);
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
