diff --git a/src/redis-shake/rump.go b/src/redis-shake/rump.go
index e22b0a4..1183c8f 100644
--- 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)