From 87feefe409ce3370d49979723eb385f89e0a35c4 Mon Sep 17 00:00:00 2001 From: CharlesCheung <61726649+CharlesCheung96@users.noreply.github.com> Date: Fri, 15 Nov 2024 01:35:33 +0800 Subject: [PATCH] use 1m channel --- 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 04ad33c2..715cd5ed 100644 --- a/pkg/eventservice/event_broker.go +++ b/pkg/eventservice/event_broker.go @@ -103,7 +103,7 @@ func newEventBroker( eventStore: eventStore, mounter: pevent.NewMounter(tz), schemaStore: schemaStore, - notifyCh: make(chan *dispatcherStat, defaultChannelSize*16), + notifyCh: make(chan *dispatcherStat, 1024*1024), dispatchers: sync.Map{}, tableTriggerDispatchers: sync.Map{}, msgSender: mc,