Skip to content

Commit 0a1ab5f

Browse files
author
ffffwh
committed
fix #732 missing rotate cause stuck
1 parent f500a55 commit 0a1ab5f

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

drivers/mysql/mysql/binlog/binlog_reader.go

+1
Original file line numberDiff line numberDiff line change
@@ -447,6 +447,7 @@ func (b *BinlogReader) handleEvent(ev *replication.BinlogEvent, entriesChannel c
447447
entry.Coordinates.GNO = evt.GNO
448448
entry.Coordinates.LastCommitted = evt.LastCommitted
449449
entry.Coordinates.SeqenceNumber = evt.SequenceNumber
450+
entry.Coordinates.LogFile = b.currentCoord.LogFile
450451

451452
b.currentBinlogEntry = entry
452453
b.hasBeginQuery = false

0 commit comments

Comments
 (0)