Skip to content

Commit f6e1379

Browse files
committed
tiny improvement to "begin to re-sync from" message
1 parent ae858cb commit f6e1379

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

replication/binlogsyncer.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -570,7 +570,12 @@ func (b *BinlogSyncer) retrySync() error {
570570
b.parser.Reset()
571571

572572
if b.prevGset != nil {
573-
log.Infof("begin to re-sync from %s", b.prevGset.String())
573+
msg := fmt.Sprintf("begin to re-sync from %s", b.prevGset.String())
574+
if b.currGset != nil {
575+
msg = fmt.Sprintf("%v (last read GTID=%v)", msg, b.currGset)
576+
}
577+
log.Infof(msg)
578+
574579
if err := b.prepareSyncGTID(b.prevGset); err != nil {
575580
return errors.Trace(err)
576581
}

0 commit comments

Comments
 (0)