From 7abc523968119f02549f2ff9f6e0b1ef1b83e62a Mon Sep 17 00:00:00 2001
From: hongyunyan <649330952@qq.com>
Date: Thu, 14 Nov 2024 17:32:24 +0800
Subject: [PATCH] udpate

---
 .../dispatchermanager/event_dispatcher_manager.go    | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/downstreamadapter/dispatchermanager/event_dispatcher_manager.go b/downstreamadapter/dispatchermanager/event_dispatcher_manager.go
index f1f5fe16e..686065ba8 100644
--- a/downstreamadapter/dispatchermanager/event_dispatcher_manager.go
+++ b/downstreamadapter/dispatchermanager/event_dispatcher_manager.go
@@ -310,6 +310,10 @@ func (e *EventDispatcherManager) newDispatchers(infos []dispatcherCreateInfo) er
 		return errors.Trace(err)
 	}
 
+	log.Info("hyy batch create new dispatchers after check startTs",
+		zap.Int("count", len(dispatcherIds)),
+		zap.Duration("duration", time.Since(start)))
+
 	for idx, id := range dispatcherIds {
 		if newStartTsList[idx] == -1 {
 			e.statusesChan <- &heartbeatpb.TableSpanStatus{
@@ -345,6 +349,10 @@ func (e *EventDispatcherManager) newDispatchers(infos []dispatcherCreateInfo) er
 			pdTsList[idx],
 			e.errCh)
 
+		log.Info("hyy batch create new dispatchers after create dispatcher",
+			zap.Int("count", len(dispatcherIds)),
+			zap.Duration("duration", time.Since(start)))
+
 		if e.heartBeatTask == nil {
 			e.heartBeatTask = newHeartBeatTask(e)
 		}
@@ -363,6 +371,10 @@ func (e *EventDispatcherManager) newDispatchers(infos []dispatcherCreateInfo) er
 			ComponentStatus: heartbeatpb.ComponentState_Working,
 		}
 
+		log.Info("hyy batch create new dispatchers after dispatcherMap set",
+			zap.Int("count", len(dispatcherIds)),
+			zap.Duration("duration", time.Since(start)))
+
 		e.tableEventDispatcherCount.Inc()
 
 		log.Info("new dispatcher created",