diff --git a/src/cluster.c b/src/cluster.c index 4751c78f..f0a6ddeb 100644 --- a/src/cluster.c +++ b/src/cluster.c @@ -924,8 +924,10 @@ int clusterProcessPacket(clusterLink *link) { if (senderCurrentEpoch > server.cluster->currentEpoch) server.cluster->currentEpoch = senderCurrentEpoch; /* Update the sender configEpoch if it is publishing a newer one. */ - if (senderConfigEpoch > sender->configEpoch) + if (senderConfigEpoch > sender->configEpoch) { sender->configEpoch = senderConfigEpoch; + clusterSaveConfigOrDie(); + } } /* Process packets by type. */