From 7a3806acf38ef6c6eb77a3e4d2091549eef27064 Mon Sep 17 00:00:00 2001 From: tsukanov-as Date: Thu, 2 Nov 2023 12:51:04 +0300 Subject: [PATCH] Make SyncedTimestamp goroutine-safe --- canal/canal.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 {