test

GMHDBJD · Dec 26, 2024 · ac85936 · ac85936
1 parent 4ff0a45
commit ac85936
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/dm/relay/relay_writer.go b/dm/relay/relay_writer.go
@@ -222,6 +222,7 @@ func (w *FileWriter) handleRotateEvent(ev *replication.BinlogEvent) (result WRes
 	}
 
 	result, err = w.handlePotentialHoleOrDuplicate(ev)
+	w.logger.Info("handle rotate event", zap.Reflect("header", ev.Header), zap.String("file", w.filename.Load()))
 	if err != nil {
 		return result, err
 	} else if result.Ignore {
@@ -244,6 +245,7 @@ func (w *FileWriter) handleRotateEvent(ev *replication.BinlogEvent) (result WRes
 //  3. write the non-duplicate event
 func (w *FileWriter) handleEventDefault(ev *replication.BinlogEvent) (WResult, error) {
 	result, err := w.handlePotentialHoleOrDuplicate(ev)
+	w.logger.Info("handle non-special event", zap.Reflect("header", ev.Header), zap.String("file", w.filename.Load()))
 	if err != nil {
 		return WResult{}, err
 	} else if result.Ignore {
@@ -302,6 +304,7 @@ func (w *FileWriter) handlePotentialHoleOrDuplicate(ev *replication.BinlogEvent)
 			return result, nil
 		}
 	}
+	w.logger.Info("handle ptential hole or duplicate event", zap.Reflect("header", ev.Header), zap.String("file", w.filename.Load()))
 
 	return WResult{
 		Ignore: false,