fix ErrSchemaStorageTableMiss error

pingcap · Jul 30, 2021 · 0c28a56 · 0c28a56
1 parent abb7abd
commit 0c28a56
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/cdc/owner/ddl_puller.go b/cdc/owner/ddl_puller.go
@@ -53,6 +53,7 @@ type ddlPullerImpl struct {
 	resolvedTS     uint64
 	pendingDDLJobs []*timodel.Job
 	cancel         context.CancelFunc
+	lastDDLJobID   int64
 }
 
 func newDDLPuller(ctx cdcContext.Context, startTs uint64) (DDLPuller, error) {
@@ -119,7 +120,12 @@ func (h *ddlPullerImpl) Run(ctx cdcContext.Context) error {
 		}
 		h.mu.Lock()
 		defer h.mu.Unlock()
+		if job.ID == h.lastDDLJobID {
+			log.Warn("ignore duplicated DDL job", zap.Any("job", job))
+			return nil
+		}
 		h.pendingDDLJobs = append(h.pendingDDLJobs, job)
+		h.lastDDLJobID = job.ID
 		return nil
 	}