mirror of https://github.com/milvus-io/milvus.git
Fix querycoord handle offline node with wrong nodeID (#18590)
Signed-off-by: xige-16 <xi.ge@zilliz.com>pull/18541/head
parent
1366f130a2
commit
29384ddbc0
|
@ -369,8 +369,8 @@ func (qc *QueryCoord) watchNodeLoop() {
|
||||||
offlineNodes := qc.cluster.OfflineNodeIDs()
|
offlineNodes := qc.cluster.OfflineNodeIDs()
|
||||||
if len(offlineNodes) != 0 {
|
if len(offlineNodes) != 0 {
|
||||||
log.Warn("find querynode down while coord not alive", zap.Any("nodeIDs", offlineNodes))
|
log.Warn("find querynode down while coord not alive", zap.Any("nodeIDs", offlineNodes))
|
||||||
for node := range offlineNodes {
|
for _, node := range offlineNodes {
|
||||||
qc.offlineNodesChan <- UniqueID(node)
|
qc.offlineNodesChan <- node
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue