diff --git a/redis-manager-dashboard/src/main/java/com/newegg/ec/redis/service/impl/RedisService.java b/redis-manager-dashboard/src/main/java/com/newegg/ec/redis/service/impl/RedisService.java index 19423ea9..86ac07be 100644 --- a/redis-manager-dashboard/src/main/java/com/newegg/ec/redis/service/impl/RedisService.java +++ b/redis-manager-dashboard/src/main/java/com/newegg/ec/redis/service/impl/RedisService.java @@ -583,7 +583,7 @@ public boolean clusterMoveSlots(Cluster cluster, RedisNode targetNode, SlotBalan do { keyList = sourceRedisClient.clusterGetKeysInSlot(slot, 50); String[] keys = keyList.toArray(new String[0]); - sourceRedisClient.migrate(sourceNode.getHost(), sourceNode.getPort(), + sourceRedisClient.migrate(targetNode.getHost(), targetNode.getPort(), 0, 100000, MigrateParams.migrateParams().replace(), keys); } while (!keyList.isEmpty()); } catch (Exception e) {