Revert changes done to engine for the moment.

pingcap · Nov 28, 2024 · 86f36fc · 86f36fc
1 parent af0411b
commit 86f36fc
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/engine/jobmaster/dm/task_manager.go b/engine/jobmaster/dm/task_manager.go
@@ -287,8 +287,7 @@ func (tm *TaskManager) allFinished(ctx context.Context) bool {
 			if runningTask.Unit != frameModel.WorkerDMLoad {
 				return false
 			}
-		case dmconfig.ModeDump, dmconfig.ModeLoad:
-			// passing through, as long as the stage is done
+		case dmconfig.ModeDump:
 		default:
 			return false
 		}

diff --git a/engine/jobmaster/dm/worker_manager.go b/engine/jobmaster/dm/worker_manager.go
@@ -302,9 +302,6 @@ var workerSeqMap = map[string][]frameModel.WorkerType{
 	dmconfig.ModeDump: {
 		frameModel.WorkerDMDump,
 	},
-	dmconfig.ModeLoad: {
-		frameModel.WorkerDMLoad,
-	},
 	dmconfig.ModeLoadSync: {
 		frameModel.WorkerDMLoad,
 		frameModel.WorkerDMSync,