This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 5ed90c91726 branch-4.0: [enhance](job) optimize auto resume rule to
adapt VCG failover #59421 (#59424)
5ed90c91726 is described below
commit 5ed90c917263ba42569155b0fdc1979b1c036e3e
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Dec 29 10:51:38 2025 +0800
branch-4.0: [enhance](job) optimize auto resume rule to adapt VCG failover
#59421 (#59424)
Cherry-picked from #59421
Co-authored-by: hui lai <[email protected]>
---
fe/fe-common/src/main/java/org/apache/doris/common/Config.java | 6 ------
.../java/org/apache/doris/load/routineload/ScheduleRule.java | 10 ----------
2 files changed, 16 deletions(-)
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 c91faab9661..73d7a1b39ab 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
@@ -1381,12 +1381,6 @@ public class Config extends ConfigBase {
@ConfField
public static boolean check_java_version = true;
- /**
- * it can't auto-resume routine load job as long as one of the backends is
down
- */
- @ConfField(mutable = true, masterOnly = true)
- public static int max_tolerable_backend_down_num = 0;
-
/**
* a period for auto resume routine load
*/
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java
index 8454bba7303..aff189a7c37 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java
@@ -59,16 +59,6 @@ public class ScheduleRule {
&& jobRoutine.pauseReason.getCode() !=
InternalErrorCode.MANUAL_PAUSE_ERR
&& jobRoutine.pauseReason.getCode() !=
InternalErrorCode.TOO_MANY_FAILURE_ROWS_ERR
&& jobRoutine.pauseReason.getCode() !=
InternalErrorCode.CANNOT_RESUME_ERR) {
- int dead = deadBeCount();
- if (dead > Config.max_tolerable_backend_down_num) {
- if (LOG.isDebugEnabled()) {
- LOG.debug("dead backend num {} is larger than config {}, "
- + "routine load job {} can not be auto
rescheduled",
- dead, Config.max_tolerable_backend_down_num,
jobRoutine.id);
- }
- return false;
- }
-
if (jobRoutine.latestResumeTimestamp == 0) { //the first resume
jobRoutine.latestResumeTimestamp = System.currentTimeMillis();
jobRoutine.autoResumeCount = 1;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
