ddl: sync the job access in failpoint mockParallelSameDDLJobTwice

pingcap · Apr 13, 2023 · b87d0ae · b87d0ae
1 parent bc14799
commit b87d0ae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ddl/ddl.go b/ddl/ddl.go
@@ -1056,11 +1056,11 @@ func (d *ddl) DoDDLJob(ctx sessionctx.Context, job *model.Job) error {
 
 	failpoint.Inject("mockParallelSameDDLJobTwice", func(val failpoint.Value) {
 		if val.(bool) {
+			<-task.err
 			// The same job will be put to the DDL queue twice.
 			job = job.Clone()
 			task1 := &limitJobTask{job, make(chan error)}
 			d.limitJobCh <- task1
-			<-task.err
 			// The second job result is used for test.
 			task = task1
 		}