From 66114988c352cef0523ff08a3aef39fec07c495b Mon Sep 17 00:00:00 2001
From: hongyunyan <649330952@qq.com>
Date: Tue, 11 Mar 2025 11:39:46 +0800
Subject: [PATCH] Fix generation of syncpoint event (#1072)

---
 pkg/eventservice/event_broker.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/eventservice/event_broker.go b/pkg/eventservice/event_broker.go
index 74fbdb159..9b77dbb5f 100644
--- 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,