diff --git a/canal/canal.go b/canal/canal.go index 989c4e297..d6b0cb9f2 100644 --- a/canal/canal.go +++ b/canal/canal.go @@ -535,7 +535,7 @@ func (c *Canal) SyncedPosition() mysql.Position { } func (c *Canal) SyncedTimestamp() uint32 { - return c.master.timestamp + return c.master.Timestamp() } func (c *Canal) SyncedGTIDSet() mysql.GTIDSet {