Skip to content

Commit 6ed701d

Browse files
committed
optimize auto resume rule to adapt VCG failover
1 parent a09eaa6 commit 6ed701d

File tree

2 files changed

+0
-16
lines changed

2 files changed

+0
-16
lines changed

fe/fe-common/src/main/java/org/apache/doris/common/Config.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1359,12 +1359,6 @@ public class Config extends ConfigBase {
13591359
@ConfField
13601360
public static boolean check_java_version = true;
13611361

1362-
/**
1363-
* it can't auto-resume routine load job as long as one of the backends is down
1364-
*/
1365-
@ConfField(mutable = true, masterOnly = true)
1366-
public static int max_tolerable_backend_down_num = 0;
1367-
13681362
/**
13691363
* a period for auto resume routine load
13701364
*/

fe/fe-core/src/main/java/org/apache/doris/load/routineload/ScheduleRule.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -59,16 +59,6 @@ public static boolean isNeedAutoSchedule(RoutineLoadJob jobRoutine) {
5959
&& jobRoutine.pauseReason.getCode() != InternalErrorCode.MANUAL_PAUSE_ERR
6060
&& jobRoutine.pauseReason.getCode() != InternalErrorCode.TOO_MANY_FAILURE_ROWS_ERR
6161
&& jobRoutine.pauseReason.getCode() != InternalErrorCode.CANNOT_RESUME_ERR) {
62-
int dead = deadBeCount();
63-
if (dead > Config.max_tolerable_backend_down_num) {
64-
if (LOG.isDebugEnabled()) {
65-
LOG.debug("dead backend num {} is larger than config {}, "
66-
+ "routine load job {} can not be auto rescheduled",
67-
dead, Config.max_tolerable_backend_down_num, jobRoutine.id);
68-
}
69-
return false;
70-
}
71-
7262
if (jobRoutine.latestResumeTimestamp == 0) { //the first resume
7363
jobRoutine.latestResumeTimestamp = System.currentTimeMillis();
7464
jobRoutine.autoResumeCount = 1;

0 commit comments

Comments
 (0)