diff --git a/src/server/cluster/cluster_config.cc b/src/server/cluster/cluster_config.cc index 675b52e42241..c86786c84d2a 100644 --- a/src/server/cluster/cluster_config.cc +++ b/src/server/cluster/cluster_config.cc @@ -99,7 +99,9 @@ shared_ptr ClusterConfig::CreateFromConfig(string_view my_id, [&](const ClusterNodeInfo& node) { return node.id == my_id; }); if (owned_by_me) { result->my_slots_.Set(shard.slot_ranges, true); - result->my_outgoing_migrations_ = shard.migrations; + if (shard.master.id == my_id) { + result->my_outgoing_migrations_ = shard.migrations; + } } else { for (const auto& m : shard.migrations) { if (my_id == m.node_info.id) {