diff --git a/src/redis-shake/common/utils.go b/src/redis-shake/common/utils.go
index 4ebfa0a..9103dcd 100644
--- a/src/redis-shake/common/utils.go
+++ b/src/redis-shake/common/utils.go
@@ -842,7 +842,7 @@ RESTORE:
 				if conf.Options.TargetReplace {
 					params = append(params, "REPLACE")
 				} else {
-					_, err = redigo.String(c.Do("del", e.Key))
+					_, err = redigoCluster.Int(c.Do("del", e.Key))
 					if err != nil {
 						log.Panicf("delete key[%v] failed[%v]", string(e.Key), err)
 					}