fix:[2.6]Reduce qc check node in replica interval for test (#45838)

issue: #45791 
master pr: #45837

Signed-off-by: Cai Zhang <cai.zhang@zilliz.com>
This commit is contained in:
cai.zhang 2025-11-27 15:09:09 +08:00 committed by GitHub
parent 195022a8f0
commit 58e4673081
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 11 additions and 0 deletions

View File

@ -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)
}
} }
} }

View File

@ -82,6 +82,8 @@ extraConfigFiles:
queryNode: queryNode:
segcore: segcore:
exprEvalBatchSize: 512 exprEvalBatchSize: 512
queryCoord:
checkNodeInReplicaInterval: 3
metrics: metrics:
serviceMonitor: serviceMonitor:
enabled: true enabled: true

View File

@ -91,6 +91,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

View File

@ -87,6 +87,8 @@ extraConfigFiles:
queryNode: queryNode:
segcore: segcore:
exprEvalBatchSize: 512 exprEvalBatchSize: 512
queryCoord:
checkNodeInReplicaInterval: 3
metrics: metrics:
serviceMonitor: serviceMonitor:
enabled: true enabled: true