Fix generation of syncpoint event (#1072)

pingcap · Mar 11, 2025 · 6611498 · 6611498
1 parent 7185573
commit 6611498
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/eventservice/event_broker.go b/pkg/eventservice/event_broker.go
@@ -414,7 +414,7 @@ func (c *eventBroker) checkAndSendHandshake(task scanTask) bool {
 // We need call this function every time we send a event(whether dml/ddl/resolvedTs),
 // thus to ensure the sync point event is in correct order for each dispatcher.
 func (c *eventBroker) emitSyncPointEventIfNeeded(ts uint64, d *dispatcherStat, remoteID node.ID) {
-	if d.enableSyncPoint && ts > d.nextSyncPoint {
+	for d.enableSyncPoint && ts > d.nextSyncPoint {
 		// Send the sync point event.
 		syncPointEvent := newWrapSyncPointEvent(
 			remoteID,