diff --git a/downstreamadapter/dispatchermanager/event_dispatcher_manager.go b/downstreamadapter/dispatchermanager/event_dispatcher_manager.go
index 915aa9b9..4d8709d4 100644
--- a/downstreamadapter/dispatchermanager/event_dispatcher_manager.go
+++ b/downstreamadapter/dispatchermanager/event_dispatcher_manager.go
@@ -109,8 +109,9 @@ func NewEventDispatcherManager(changefeedID common.ChangeFeedID,
 		dispatcherMap:                  newDispatcherMap(),
 		changefeedID:                   changefeedID,
 		maintainerID:                   maintainerID,
-		statusesChan:                   make(chan *heartbeatpb.TableSpanStatus, 10000),
-		blockStatusesChan:              make(chan *heartbeatpb.TableSpanBlockStatus, 1000),
+		statusesChan:                   make(chan *heartbeatpb.TableSpanStatus, 8192),
+		blockStatusesChan:              make(chan *heartbeatpb.TableSpanBlockStatus, 1024*1024),
+		dispatcherActionChan:           make(chan common.DispatcherAction, 1024*1024),
 		cancel:                         cancel,
 		config:                         cfConfig,
 		schemaIDToDispatchers:          dispatcher.NewSchemaIDToDispatchers(),
@@ -423,6 +424,7 @@ func (e *EventDispatcherManager) CollectDispatcherAction(ctx context.Context) {
 		case <-ctx.Done():
 			return
 		case a := <-e.dispatcherActionChan:
+			log.Info("collect dispatcher action", zap.String("action", a.String()))
 			d, ok := e.dispatcherMap.Get(a.DispatcherID)
 			if !ok {
 				continue