double check policy exits

pingcap · Oct 8, 2021 · bdf86be · bdf86be
1 parent 3dc19b2
commit bdf86be
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/ddl/schema.go b/ddl/schema.go
@@ -154,6 +154,11 @@ func onModifySchemaDefaultPlacement(t *meta.Meta, job *model.Job) (ver int64, _
 	if err != nil {
 		return ver, errors.Trace(err)
 	}
+	//Double Check if policy exits while ddl executing
+	_, err = checkPlacementPolicyExistAndCancelNonExistJob(t, job, placementPolicyRef.ID)
+	if err != nil {
+		return ver, errors.Trace(err)
+	}
 
 	// Notice: dbInfo.DirectPlacementOpts and dbInfo.PlacementPolicyRef can not be both not nil, which checked before constructing ddl job.
 	// So that we can just check the two situation that do not need ddl: 1. DB.DP == DDL.DP && nil == nil 2. nil == nil && DB.PP == DDL.PP