diff --git a/go/logic/applier.go b/go/logic/applier.go index a45bfe0..1514ed4 100644 --- a/go/logic/applier.go +++ b/go/logic/applier.go @@ -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 }