add captureID and changefeedID fields to warn log

pingcap · Dec 22, 2021 · 8024b79 · 8024b79
1 parent ad66686
commit 8024b79
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cdc/owner/scheduler_v1.go b/cdc/owner/scheduler_v1.go
@@ -310,7 +310,7 @@ func (s *oldScheduler) cleanUpFinishedOperations() {
 	for captureID := range s.state.TaskStatuses {
 		s.state.PatchTaskStatus(captureID, func(status *model.TaskStatus) (*model.TaskStatus, bool, error) {
 			if status == nil {
-				log.Warn("task status of the capture is not found, may be the key in etcd was deleted.")
+				log.Warn("task status of the capture is not found, may be the key in etcd was deleted", zap.Any("captureID", captureID), zap.Any("changeFeedID", s.state.ID))
 				return status, false, nil
 			}