milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ignore getReplica's error when handle rebalanceTask (#17469) 

Signed-off-by: Enwei Jiao <jiaoew2011@gmail.com>
pull/17489/head
Enwei Jiao 2022-06-10 14:50:08 +08:00 committed by GitHub
parent b64a467311
commit a5b008acec
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/querycoord/task.go
View File

@ -1935,8 +1935,9 @@ func (lbt *loadBalanceTask) processNodeDownLoadBalance(ctx context.Context) erro
log.Info("loadBalanceTask: get collection's all partitionIDs", zap.Int64("collectionID", collectionID), zap.Int64s("partitionIDs", toRecoverPartitionIDs))
replica, err := lbt.getReplica(nodeID, collectionID)
if err != nil {
lbt.setResultInfo(err)
return err
// getReplica maybe failed, it will cause the balanceTask execute infinitely
log.Warn("loadBalanceTask: get replica failed", zap.Int64("collectionID", collectionID), zap.Int64("nodeId", nodeID))
continue
}
for _, partitionID := range toRecoverPartitionIDs {