update

pingcap · Jan 10, 2025 · d878d68 · d878d68
1 parent 1f1f31e
commit d878d68
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 3 deletions.
diff --git a/coordinator/changefeed/changefeed.go b/coordinator/changefeed/changefeed.go
@@ -122,7 +122,6 @@ func (c *Changefeed) ShouldRun() bool {
 }
 
 func (c *Changefeed) UpdateStatus(newStatus *heartbeatpb.MaintainerStatus) (bool, model.FeedState, *heartbeatpb.RunningError) {
-	log.Info("hyy changefeed updatestatus", zap.Any("status", newStatus))
 	old := c.status.Load()
 	if newStatus != nil && newStatus.CheckpointTs >= old.CheckpointTs {
 		c.status.Store(newStatus)
@@ -157,7 +156,6 @@ func (c *Changefeed) GetLastSavedCheckPointTs() uint64 {
 }
 
 func (c *Changefeed) NewAddMaintainerMessage(server node.ID) *messaging.TargetMessage {
-	log.Info("hyy changefeed NewAddMaintainerMessage", zap.Any("checkpointTs", c.GetStatus().CheckpointTs), zap.Any("isNew", c.isNew))
 	return messaging.NewSingleTargetMessage(server,
 		messaging.MaintainerManagerTopic,
 		&heartbeatpb.AddMaintainerRequest{

diff --git a/coordinator/coordinator.go b/coordinator/coordinator.go
@@ -160,7 +160,6 @@ func (c *coordinator) Run(ctx context.Context) error {
 }
 
 func (c *coordinator) handleStateChangedEvent(ctx context.Context, event *ChangefeedStateChangeEvent) error {
-	log.Info("hyy coordinator handleStateChangedEvent", zap.Any("event", event))
 	cf := c.controller.GetTask(event.ChangefeedID)
 	if cf == nil {
 		log.Warn("changefeed not found", zap.String("changefeed", event.ChangefeedID.String()))