Skip to content

Commit fc01122

Browse files
author
ffffwh
committed
fixup! add job config: TwoWaySyncGtid
1 parent 9d8513e commit fc01122

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

api/handler/v2/job.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -589,7 +589,7 @@ func buildDatabaseSrcTaskConfigMap(config *models.SrcTaskConfig, destConfig *mod
589589
addNotRequiredParamToMap(taskConfigInNomadFormat, config.MysqlSrcTaskConfig.ExpandSyntaxSupport, "ExpandSyntaxSupport")
590590
addNotRequiredParamToMap(taskConfigInNomadFormat, config.MysqlSrcTaskConfig.DumpEntryLimit, "DumpEntryLimit")
591591
addNotRequiredParamToMap(taskConfigInNomadFormat, config.MysqlSrcTaskConfig.TwoWaySync, "TwoWaySync")
592-
addNotRequiredParamToMap(taskConfigInNomadFormat, config.MysqlSrcTaskConfig.TwoWaySync, "TwoWaySyncGtid")
592+
addNotRequiredParamToMap(taskConfigInNomadFormat, config.MysqlSrcTaskConfig.TwoWaySyncGtid, "TwoWaySyncGtid")
593593
taskConfigInNomadFormat["SrcConnectionConfig"] = buildMysqlConnectionConfigMap(config.ConnectionConfig)
594594
}
595595
// for Oracle

driver/mysql/applier.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -260,7 +260,7 @@ func (a *Applier) prepareGTID() {
260260

261261
a.gtidSet, err = common.DtleParseMysqlGTIDSet(a.mysqlContext.Gtid)
262262
if err != nil {
263-
a.onError(common.TaskStateDead, errors.Wrap(err, "DtleParseMysqlGTIDSet"))
263+
a.onError(common.TaskStateDead, errors.Wrapf(err, "DtleParseMysqlGTIDSet %v", a.mysqlContext.Gtid))
264264
}
265265
return
266266
}

0 commit comments

Comments
 (0)