rewinding resurrecting at beginning of known logfile; more verbose

This commit is contained in:
Shlomi Noach 2016-12-28 07:42:14 +02:00
parent 874cf24512
commit 8952e24aba
2 changed files with 5 additions and 0 deletions

View File

@ -307,6 +307,9 @@ func (this *Migrator) applyResurrectedContext() error {
return err
}
log.Infof("Applied migration min values: [%s]", this.migrationContext.MigrationRangeMinValues)
log.Infof("Applied migration max values: [%s]", this.migrationContext.MigrationRangeMaxValues)
return nil
}

View File

@ -114,6 +114,8 @@ func (this *EventsStreamer) InitDBConnections(resurrectedContext *base.Migration
return err
}
if this.migrationContext.Resurrect {
// Rewinding to beginning of logfile:
resurrectedContext.AppliedBinlogCoordinates.LogPos = 4
log.Infof("Resurrection: initiating streamer at resurrected coordinates %+v", resurrectedContext.AppliedBinlogCoordinates)
this.initialBinlogCoordinates = &resurrectedContext.AppliedBinlogCoordinates
} else {