remove unnecessary delay

pingcap · Sep 16, 2022 · 5cd4a7a · 5cd4a7a
1 parent 0a0aa77
commit 5cd4a7a
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/ddl/reorg.go b/ddl/reorg.go
@@ -254,11 +254,9 @@ func (w *worker) runReorgJob(rh *reorgHandler, reorgInfo *reorgInfo, tblInfo *mo
 		}
 
 		updateBackfillProgress(w, reorgInfo, tblInfo, 0)
-		if job.ReorgMeta.ReorgTp != model.ReorgTypeLitMerge || reorgInfo.mergingTmpIdx {
-			if err1 := rh.RemoveDDLReorgHandle(job, reorgInfo.elements); err1 != nil {
-				logutil.BgLogger().Warn("[ddl] run reorg job done, removeDDLReorgHandle failed", zap.Error(err1))
-				return errors.Trace(err1)
-			}
+		if err1 := rh.RemoveDDLReorgHandle(job, reorgInfo.elements); err1 != nil {
+			logutil.BgLogger().Warn("[ddl] run reorg job done, removeDDLReorgHandle failed", zap.Error(err1))
+			return errors.Trace(err1)
 		}
 	case <-w.ctx.Done():
 		logutil.BgLogger().Info("[ddl] run reorg job quit")