refactor ddl puller handle jobs.

pingcap · Dec 13, 2023 · 694fca2 · 694fca2
1 parent d9a80e2
commit 694fca2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/cdc/puller/ddl_puller.go b/cdc/puller/ddl_puller.go
@@ -663,6 +663,9 @@ func NewDDLPuller(ctx context.Context,
 }
 
 func (h *ddlPullerImpl) add2Pending(job *timodel.Job) {
+	if job == nil {
+		return
+	}
 	if job.ID == h.lastDDLJobID {
 		log.Warn("ignore duplicated DDL job",
 			zap.String("namespace", h.changefeedID.Namespace),
@@ -713,6 +716,7 @@ func (h *ddlPullerImpl) Run(ctx context.Context) error {
 					if entry.CRTs > atomic.LoadUint64(&h.resolvedTS) {
 						atomic.StoreUint64(&h.resolvedTS, entry.CRTs)
 						lastResolvedTsAdvancedTime = cc.Now()
+						continue
 					}
 				}
 				h.add2Pending(entry.Job)