Merge pull request #281 from akshaychhajed/tungsten-check

Modified slave update check to test tungsten flag
This commit is contained in:
Shlomi Noach 2016-10-19 21:00:31 +02:00 committed by GitHub
commit 1a76c044bf

View File

@ -327,7 +327,7 @@ func (this *Inspector) validateLogSlaveUpdates() error {
if err := this.db.QueryRow(query).Scan(&logSlaveUpdates); err != nil { if err := this.db.QueryRow(query).Scan(&logSlaveUpdates); err != nil {
return err return err
} }
if !logSlaveUpdates && !this.migrationContext.InspectorIsAlsoApplier() { if !logSlaveUpdates && !this.migrationContext.InspectorIsAlsoApplier() && !this.migrationContext.IsTungsten {
return fmt.Errorf("%s:%d must have log_slave_updates enabled", this.connectionConfig.Key.Hostname, this.connectionConfig.Key.Port) return fmt.Errorf("%s:%d must have log_slave_updates enabled", this.connectionConfig.Key.Hostname, this.connectionConfig.Key.Port)
} }