Update canal/dump.go

serprex · dveeden · web-flow · commit a9b1ebce732e · 2025-03-04T14:28:10.000Z
Co-authored-by: Daniël van Eeden &lt;github@myname.nl&gt;
diff --git a/canal/dump.go b/canal/dump.go
@@ -164,7 +164,7 @@ func (c *Canal) dump() error {
 		if err != nil {
 			return errors.Trace(err)
 		}
-		c.cfg.Logger.Info("skip master data, get current binlog position", slog.Any("pos", pos))
+		c.cfg.Logger.Info("skip master data, get current binlog position", slog.Any("position", pos))
 		h.name = pos.Name
 		h.pos = uint64(pos.Pos)
 	}

Original file line number	Diff line number	Diff line change
`@@ -164,7 +164,7 @@ func (c *Canal) dump() error {`
`164`	`164`	`if err != nil {`
`165`	`165`	`return errors.Trace(err)`
`166`	`166`	`}`
`167`		`- c.cfg.Logger.Info("skip master data, get current binlog position", slog.Any("pos", pos))`
	`167`	`+ c.cfg.Logger.Info("skip master data, get current binlog position", slog.Any("position", pos))`
`168`	`168`	`h.name = pos.Name`
`169`	`169`	`h.pos = uint64(pos.Pos)`
`170`	`170`	`}`