merge PR #111

5 years ago · fedeb66e6c
parent 4a85f9bd07 82c2156d94
commit fedeb66e6c
1 changed files with 1 additions and 1 deletions
--- a/src/redis-shake/rump.go
+++ b/src/redis-shake/rump.go
@ -369,7 +369,7 @@ func (dre *dbRumperExecutor) writer() {
 		// dre.resultChan <- ele
 		count++
-		if count == conf.Options.ScanKeyNumber {
+		if count >= conf.Options.ScanKeyNumber {
 			// batch
 			log.Debugf("dbRumper[%v] executor[%v] send keys %d", dre.rumperId, dre.executorId, count)