diff --git a/ChangeLog b/ChangeLog index 74647183..9ed3559d 100644 --- a/ChangeLog +++ b/ChangeLog @@ -1,3 +1,7 @@ +2020-05-06 Alibaba Cloud. + * VERSION: 2.0.2 + * BUGFIX: fix bug of `target.db` isn't work in cascade replication + scenario. see #277. 2020-05-02 Alibaba Cloud. * VERSION: 2.0.1 * IMPROVE: rebase v1.6.28. diff --git a/src/redis-shake/dbSync/syncIncrease.go b/src/redis-shake/dbSync/syncIncrease.go index e0138b60..67106c66 100644 --- a/src/redis-shake/dbSync/syncIncrease.go +++ b/src/redis-shake/dbSync/syncIncrease.go @@ -158,9 +158,19 @@ func (ds *DbSyncer) parseSourceCommand(reader *bufio.Reader) { // sendMarkId atomic2.Int64 // sendMarkId is also used as mark the sendId in sender routine ) - // if the start db id != 0, send dbid to the target at first + // if enable target.db + if conf.Options.TargetDB != -1 { + ds.startDbId = conf.Options.TargetDB + } + + /* + * if the start db id != 0, send dbid to the target at first. + * there're two cases that the statDbId != 0: + * 1. enable target.db. see #277. + * 2. start from resume-from-break-point + */ if ds.startDbId != 0 { - log.Infof("last dbid[%v] != 0, send 'select' first", ds.startDbId) + log.Infof("start dbid[%v] != 0, send 'select' first", ds.startDbId) dbS := fmt.Sprintf("%d", ds.startDbId) ds.sendBuf <- cmdDetail{ Cmd: "select",