update

Author: hongyunyan

maintainer/barrier_event.go

@@ -283,10 +283,10 @@ func (be *BarrierEvent) markDispatcherEventDone(dispatcherID common.DispatcherID
 				for dispatcher := range be.reportedDispatchers {
 					replicaSpan := be.controller.GetTask(dispatcher)
 					if replicaSpan == nil {
-						log.Warn("dispatcher not found, ignore",
+						log.Info("dispatcher not found, ignore",
 							zap.String("changefeed", be.cfID.Name()),
 							zap.String("dispatcher", dispatcherID.String()))
-						return
+						continue
 					}
 					be.rangeChecker.AddSubRange(replicaSpan.Span.TableID, replicaSpan.Span.StartKey, replicaSpan.Span.EndKey)
 				}
@@ -298,10 +298,10 @@ func (be *BarrierEvent) markDispatcherEventDone(dispatcherID common.DispatcherID
 				for dispatcher := range be.reportedDispatchers {
 					replicaSpan := be.controller.GetTask(dispatcher)
 					if replicaSpan == nil {
-						log.Warn("dispatcher not found, ignore",
+						log.Info("dispatcher not found, ignore",
 							zap.String("changefeed", be.cfID.Name()),
 							zap.String("dispatcher", dispatcherID.String()))
-						return
+						continue
 					}
 					be.rangeChecker.AddSubRange(replicaSpan.Span.TableID, replicaSpan.Span.StartKey, replicaSpan.Span.EndKey)
 				}