We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8b9c05e commit 046188bCopy full SHA for 046188b
canal/sync.go
@@ -50,7 +50,11 @@ func (c *Canal) runSyncBinlog() error {
50
51
// Update the delay between the Canal and the Master before the handler hooks are called
52
c.updateReplicationDelay(ev)
53
-
+ // if log pos equal zero ,it is a fake rotate event,ignore it.
54
+ // see https://github.com/mysql/mysql-server/blob/8cc757da3d87bf4a1f07dcfb2d3c96fed3806870/sql/rpl_binlog_sender.cc#L899
55
+ if ev.Header.LogPos == 0 {
56
+ continue
57
+ }
58
savePos = false
59
force = false
60
pos := c.master.Position()
0 commit comments