From 18e0ebd07def741fea1f9ef6735b174d8e3a1aef Mon Sep 17 00:00:00 2001 From: hui lai Date: Tue, 8 Jul 2025 09:53:42 +0800 Subject: [PATCH] [fix](job) remove can not transform RUNNING to NEED_SCHEDULE limit (#52887) ### What problem does this PR solve? Routine load job could not transform RUNNING to NEED_SCHEDULE, when partition num increase and reschedule job, it will throw exception, causing new partition can not consume: ``` 2025-07-07 14:35:39,847 WARN (Routine load scheduler|41) [RoutineLoadScheduler.runAfterCatalogReady():59] Failed to process one round of RoutineLoadScheduler org.apache.doris.common.DdlException: errCode = 2, detailMessage = Could not transform RUNNING to NEED_SCHEDULE at org.apache.doris.load.routineload.RoutineLoadJob.checkStateTransform(RoutineLoadJob.java:788) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.load.routineload.RoutineLoadJob.unprotectUpdateState(RoutineLoadJob.java:1366) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.load.routineload.RoutineLoadJob.update(RoutineLoadJob.java:1483) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.load.routineload.RoutineLoadManager.updateRoutineLoadJob(RoutineLoadManager.java:839) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.load.routineload.RoutineLoadScheduler.process(RoutineLoadScheduler.java:65) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.load.routineload.RoutineLoadScheduler.runAfterCatalogReady(RoutineLoadScheduler.java:57) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.common.util.MasterDaemon.runOneCycle(MasterDaemon.java:58) ~[doris-fe.jar:1.2-SNAPSHOT] at org.apache.doris.common.util.Daemon.run(Daemon.java:116) ~[doris-fe.jar:1.2-SNAPSHOT] ``` introduced by https://github.com/apache/doris/pull/40728, and should remove this limit. --- .../org/apache/doris/load/routineload/RoutineLoadJob.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java index edef9358e00556..6c8ebe3d4788ab 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java @@ -813,11 +813,6 @@ public boolean isAbnormalPause() { // All of private method could not be call without lock private void checkStateTransform(RoutineLoadJob.JobState desireState) throws UserException { switch (state) { - case RUNNING: - if (desireState == JobState.NEED_SCHEDULE) { - throw new DdlException("Could not transform " + state + " to " + desireState); - } - break; case PAUSED: if (desireState == JobState.PAUSED) { throw new DdlException("Could not transform " + state + " to " + desireState);