diff --git a/src/cluster.c b/src/cluster.c index 6959a236e..d250dec85 100644 --- a/src/cluster.c +++ b/src/cluster.c @@ -1431,9 +1431,9 @@ void clusterCommand(redisClient *c) { /* If this node was importing this slot, assigning the slot to * itself also clears the importing status. */ - if (n == server.cluster->myself && server.cluster->importing_slots_from[slot]) + if (n == server.cluster->myself && + server.cluster->importing_slots_from[slot]) server.cluster->importing_slots_from[slot] = NULL; - clusterDelSlot(slot); clusterAddSlot(n,slot); } else {