未验证 提交 9d2e5aac 编写于 作者: B Bingyi Sun 提交者: GitHub

Fix missing dml nodeIDs when recovering from old version (#17800)

issue: #17416
Signed-off-by: Nsunby <bingyi.sun@zilliz.com>
Co-authored-by: Nsunby <bingyi.sun@zilliz.com>
上级 5471e35c
......@@ -253,9 +253,6 @@ func (m *MetaReplica) reloadFromKV() error {
nodes[nodeID] = struct{}{}
}
}
for nodeID := range nodes {
replica.NodeIds = append(replica.NodeIds, nodeID)
}
shardReplicas := make([]*milvuspb.ShardReplica, 0, len(dmChannels[collectionInfo.CollectionID]))
for _, dmc := range dmChannels[collectionInfo.CollectionID] {
......@@ -264,6 +261,12 @@ func (m *MetaReplica) reloadFromKV() error {
// LeaderAddr: Will set it after the cluster is reloaded
DmChannelName: dmc.DmChannel,
})
nodes[dmc.NodeIDLoaded] = struct{}{}
}
replica.ShardReplicas = shardReplicas
for nodeID := range nodes {
replica.NodeIds = append(replica.NodeIds, nodeID)
}
err = m.addReplica(replica)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册