diff --git a/internal/querycoordv2/dist/dist_handler.go b/internal/querycoordv2/dist/dist_handler.go index 18b6ab38a8..f1a5434f8f 100644 --- a/internal/querycoordv2/dist/dist_handler.go +++ b/internal/querycoordv2/dist/dist_handler.go @@ -181,7 +181,11 @@ func (dh *distHandler) updateChannelsDistribution(resp *querypb.GetDataDistribut Version: ch.GetVersion(), } } else { - channel = channelInfo.Clone() + channel = &meta.DmChannel{ + VchannelInfo: channelInfo.VchannelInfo, + Node: resp.GetNodeID(), + Version: ch.GetVersion(), + } } updates = append(updates, channel) }