Skip to content

Commit cd2da17

Browse files
authored
eventservice: increase table tigger dispatcher ddl fetch speed (#341)
* increase table trigger dispatcher fetch speed * fix
1 parent ac7a3a7 commit cd2da17

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/eventservice/event_broker.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -198,7 +198,7 @@ func (c *eventBroker) tickTableTriggerDispatchers(ctx context.Context) {
198198
c.wg.Add(1)
199199
go func() {
200200
defer c.wg.Done()
201-
ticker := time.NewTicker(time.Millisecond * 300)
201+
ticker := time.NewTicker(time.Millisecond * 50)
202202
defer ticker.Stop()
203203
for {
204204
select {
@@ -210,7 +210,7 @@ func (c *eventBroker) tickTableTriggerDispatchers(ctx context.Context) {
210210
startTs := dispatcher.watermark.Load()
211211
remoteID := node.ID(dispatcher.info.GetServerID())
212212
// TODO: maybe limit 1 is enough.
213-
ddlEvents, endTs, err := c.schemaStore.FetchTableTriggerDDLEvents(dispatcher.filter, startTs, 10)
213+
ddlEvents, endTs, err := c.schemaStore.FetchTableTriggerDDLEvents(dispatcher.filter, startTs, 100)
214214
if err != nil {
215215
log.Panic("get table trigger events failed", zap.Error(err))
216216
}

0 commit comments

Comments
 (0)