diff --git a/src/redis-shake/dbSync/dbSyncer.go b/src/redis-shake/dbSync/dbSyncer.go index adc6ed69..aa876627 100644 --- a/src/redis-shake/dbSync/dbSyncer.go +++ b/src/redis-shake/dbSync/dbSyncer.go @@ -117,6 +117,7 @@ func (ds *DbSyncer) Sync() { // sync input, nsize = ds.sendSyncCmd(ds.source, conf.Options.SourceAuthType, ds.sourcePassword, conf.Options.SourceTLSEnable, conf.Options.SourceTLSSkipVerify) + isFullSync = true } defer input.Close()