applier always uses UTC

This commit is contained in:
Shlomi Noach 2016-10-13 13:08:02 +02:00
parent b38af6c29e
commit ac304def4d

View File

@ -908,10 +908,10 @@ func (this *Applier) ApplyDMLEventQuery(dmlEvent *binlog.BinlogDMLEvent) error {
if err != nil {
return err
}
sessionQuery := fmt.Sprintf(`SET
SESSION time_zone = '%s',
sessionQuery := `SET
SESSION time_zone = '+00:00',
sql_mode = CONCAT(@@session.sql_mode, ',STRICT_ALL_TABLES')
`, this.migrationContext.ApplierTimeZone)
`
if _, err := tx.Exec(sessionQuery); err != nil {
return err
}