update

Author: zier-one

pkg/eventservice/event_broker.go

@@ -352,21 +352,17 @@ func (c *eventBroker) tickTableTriggerDispatchers(ctx context.Context) error {
 					ID:   stat.info.GetTableSpan().KeyspaceID,
 					Name: stat.info.GetChangefeedID().Keyspace(),
 				}
-
-				ddlEvents, endTs, err := c.schemaStore.FetchTableTriggerDDLEvents(keyspaceMeta, dispatcherID, stat.filter, startTs, 100)
+				ddlEvents, endTs, err := c.schemaStore.FetchTableTriggerDDLEvents(keyspaceMeta, key.(common.DispatcherID), stat.filter, startTs, 100)
 				if err != nil {
-					log.Error("table trigger ddl events fetch failed", zap.Uint32("keyspaceID", stat.info.GetTableSpan().KeyspaceID),
-						zap.Stringer("dispatcherID", stat.id), zap.Uint64("startTs", startTs), zap.Error(err))
+					log.Error("table trigger ddl events fetch failed", zap.Uint32("keyspaceID", stat.info.GetTableSpan().KeyspaceID), zap.Stringer("dispatcherID", stat.id), zap.Error(err))
 					return true
 				}
 				// Keep the raw resolved-ts from schema store for scan readiness/lag visibility.
 				stat.receivedResolvedTs.Store(endTs)
-
 				for _, e := range ddlEvents {
 					ep := &e
 					c.sendDDL(ctx, remoteID, ep, stat)
 				}
-
 				if endTs > startTs {
 					// After all the events are sent, we send the watermark to the dispatcher.
 					c.sendResolvedTs(stat, endTs)