[doris] branch master updated: [fix](planner) Add default execution interval time for stats framework (#13044)

[morrysnow]

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 <33112463+kikyou1...@users.noreply.github.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org