fix unit test

pingcap · Feb 16, 2023 · 3a70491 · 3a70491
1 parent d41b4f8
commit 3a70491
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/ddl/backfilling.go b/ddl/backfilling.go
@@ -1072,9 +1072,6 @@ func (dc *ddlCtx) writePhysicalTableRecord(sessPool *sessionPool, t table.Physic
 	}
 
 	for {
-		if startKey.Cmp(endKey) >= 0 {
-			break
-		}
 		kvRanges, err := splitTableRanges(t, reorgInfo.d.store, startKey, endKey, backfillTaskChanSize)
 		if err != nil {
 			return errors.Trace(err)
@@ -1111,6 +1108,9 @@ func (dc *ddlCtx) writePhysicalTableRecord(sessPool *sessionPool, t table.Physic
 		} else {
 			startKey = kvRanges[len(kvRanges)-1].EndKey
 		}
+		if startKey.Cmp(endKey) >= 0 {
+			break
+		}
 	}
 	if ingestBeCtx != nil {
 		ingestBeCtx.EngMgr.ResetWorkers(ingestBeCtx, job.ID, reorgInfo.currElement.ID)