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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
