[doris] branch master updated: [improve](alter-job) Add a config for forbiding doing alter job (#23294)

[yiguolei]

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

yiguolei 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 a4e041ea55 [improve](alter-job) Add a config for forbiding doing alter 
job (#23294)
a4e041ea55 is described below

commit a4e041ea55619ee5e0ae4ce418e55c847f47eeb1
Author: Lightman <31928846+lchangli...@users.noreply.github.com>
AuthorDate: Tue Aug 22 16:28:36 2023 +0800

    [improve](alter-job) Add a config for forbiding doing alter job (#23294)
---
 fe/fe-common/src/main/java/org/apache/doris/common/Config.java         | 3 +++
 .../src/main/java/org/apache/doris/alter/SchemaChangeHandler.java      | 3 +++
 2 files changed, 6 insertions(+)

diff --git a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java 
b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
index aa415da212..6131740e92 100644
--- a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
@@ -2111,4 +2111,7 @@ public class Config extends ConfigBase {
             "是否用 mysql 的 bigint 类型来返回 Doris 的 largeint 类型",
             "Whether to use mysql's bigint type to return Doris's largeint 
type"})
     public static boolean use_mysql_bigint_for_largeint = false;
+
+    @ConfField
+    public static boolean forbid_running_alter_job = false;
 }
diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeHandler.java 
b/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeHandler.java
index b555516bc2..14946d18c0 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeHandler.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/alter/SchemaChangeHandler.java
@@ -1602,6 +1602,9 @@ public class SchemaChangeHandler extends AlterHandler {
     }
 
     private void runAlterJobV2() {
+        if (Config.forbid_running_alter_job) {
+            return;
+        }
         runnableSchemaChangeJobV2.values().forEach(alterJobsV2 -> {
             if (!alterJobsV2.isDone() && 
!activeSchemaChangeJobsV2.containsKey(alterJobsV2.getJobId())
                     && activeSchemaChangeJobsV2.size() < 
MAX_ACTIVE_SCHEMA_CHANGE_JOB_V2_SIZE) {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org