mirror of
https://gitee.com/milvus-io/milvus.git
synced 2025-12-06 17:18:35 +08:00
fix: Reduce querycoord check node in replica interval for test (#45837)
issue: #45791 Signed-off-by: Cai Zhang <cai.zhang@zilliz.com>
This commit is contained in:
parent
464a805c63
commit
7c9a9c6f7e
@ -177,6 +177,7 @@ func (ob *ReplicaObserver) checkNodesInReplica() {
|
|||||||
// check all ro nodes, remove it from replica if all segment/channel has been moved
|
// check all ro nodes, remove it from replica if all segment/channel has been moved
|
||||||
for _, collectionID := range collections {
|
for _, collectionID := range collections {
|
||||||
replicas := ob.meta.ReplicaManager.GetByCollection(ctx, collectionID)
|
replicas := ob.meta.ReplicaManager.GetByCollection(ctx, collectionID)
|
||||||
|
hasNodeRemoved := false
|
||||||
for _, replica := range replicas {
|
for _, replica := range replicas {
|
||||||
if enableChannelExclusiveMode && !replica.IsChannelExclusiveModeEnabled() {
|
if enableChannelExclusiveMode && !replica.IsChannelExclusiveModeEnabled() {
|
||||||
// register channel for enable exclusive mode
|
// register channel for enable exclusive mode
|
||||||
@ -217,9 +218,13 @@ func (ob *ReplicaObserver) checkNodesInReplica() {
|
|||||||
zap.Error(err))
|
zap.Error(err))
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
hasNodeRemoved = true
|
||||||
logger.Info("all segment/channel has been removed from ro node, remove it from replica",
|
logger.Info("all segment/channel has been removed from ro node, remove it from replica",
|
||||||
zap.Int64s("removedNodes", removeNodes),
|
zap.Int64s("removedNodes", removeNodes),
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
if hasNodeRemoved {
|
||||||
|
utils.RecoverReplicaOfCollection(ctx, ob.meta, collectionID)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -89,6 +89,8 @@ extraConfigFiles:
|
|||||||
queryNode:
|
queryNode:
|
||||||
segcore:
|
segcore:
|
||||||
exprEvalBatchSize: 512
|
exprEvalBatchSize: 512
|
||||||
|
queryCoord:
|
||||||
|
checkNodeInReplicaInterval: 3
|
||||||
metrics:
|
metrics:
|
||||||
serviceMonitor:
|
serviceMonitor:
|
||||||
enabled: true
|
enabled: true
|
||||||
|
|||||||
@ -98,6 +98,8 @@ extraConfigFiles:
|
|||||||
scalarField: true
|
scalarField: true
|
||||||
scalarIndex: true
|
scalarIndex: true
|
||||||
growingMmapEnabled: true
|
growingMmapEnabled: true
|
||||||
|
queryCoord:
|
||||||
|
checkNodeInReplicaInterval: 3
|
||||||
metrics:
|
metrics:
|
||||||
serviceMonitor:
|
serviceMonitor:
|
||||||
enabled: true
|
enabled: true
|
||||||
|
|||||||
@ -94,6 +94,8 @@ extraConfigFiles:
|
|||||||
queryNode:
|
queryNode:
|
||||||
segcore:
|
segcore:
|
||||||
exprEvalBatchSize: 512
|
exprEvalBatchSize: 512
|
||||||
|
queryCoord:
|
||||||
|
checkNodeInReplicaInterval: 3
|
||||||
metrics:
|
metrics:
|
||||||
serviceMonitor:
|
serviceMonitor:
|
||||||
enabled: true
|
enabled: true
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user