diff --git a/src/cluster.c b/src/cluster.c index 3d19d078..fe8675f2 100644 --- a/src/cluster.c +++ b/src/cluster.c @@ -854,7 +854,10 @@ int clusterProcessPacket(clusterLink *link) { sender->flags &= ~REDIS_NODE_MASTER; sender->flags |= REDIS_NODE_SLAVE; if (sender->numslaves) clusterNodeResetSlaves(sender); - if (master) clusterNodeAddSlave(master,sender); + if (master) { + clusterNodeAddSlave(master,sender); + sender->slaveof = master; + } } }