admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-07 17:48:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

[skip e2e] add log for querynode load and remove segment(#20510) (#20810)

Browse Source 
issue: #20510

Signed-off-by: MrPresent-Han <jamesharden11122@gmail.com>

Signed-off-by: MrPresent-Han <jamesharden11122@gmail.com>
This commit is contained in:
MrPresent-Han 2022-11-25 17:33:13 +08:00 committed by GitHub
parent 49c8ce7561
commit b021d7c59c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/querycoordv2/observers/leader_observer.go
View File

@ -134,6 +134,11 @@ func (o *LeaderObserver) findNeedRemovedSegments(leaderView *meta.LeaderView, di
if ok || existInCurrentTarget || existInNextTarget { if ok || existInCurrentTarget || existInNextTarget {
continue continue
} }
log.Debug("leader observer append a segment to remove:", zap.Int64("collectionID", leaderView.CollectionID),
zap.String("Channel", leaderView.Channel), zap.Int64("leaderViewID", leaderView.ID),
zap.Int64("segmentID", sid), zap.Bool("distMap_exist", ok),
zap.Bool("existInCurrentTarget", existInCurrentTarget),
zap.Bool("existInNextTarget", existInNextTarget))
ret = append(ret, &querypb.SyncAction{ ret = append(ret, &querypb.SyncAction{
Type: querypb.SyncType_Remove, Type: querypb.SyncType_Remove,
SegmentID: sid, SegmentID: sid,

3
internal/querynode/shard_cluster.go
View File

@ -647,6 +647,9 @@ func (sc *ShardCluster) LoadSegments(ctx context.Context, req *querypb.LoadSegme
log.Warn("follower load segment failed", zap.String("reason", resp.GetReason())) log.Warn("follower load segment failed", zap.String("reason", resp.GetReason()))
return fmt.Errorf("follower %d failed to load segment, reason %s", req.DstNodeID, resp.GetReason()) return fmt.Errorf("follower %d failed to load segment, reason %s", req.DstNodeID, resp.GetReason())
} }
log.Debug("shardCluster has completed loading segments for:",
zap.Int64("collectionID:", req.CollectionID), zap.Int64("replicaID:", req.ReplicaID),
zap.Int64("sourceNodeId", req.SourceNodeID))
// update allocation // update allocation
for _, info := range req.Infos { for _, info := range req.Infos {