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 ac6ee280d25333..19ed1d3db7ff88 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 @@ -1319,12 +1319,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 8454bba73031ca..aff189a7c37865 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 static boolean isNeedAutoSchedule(RoutineLoadJob jobRoutine) { && 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;