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

Add more logs for debugging load balance (#21390) 

Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
pull/21419/head
Xiaofan 2022-12-27 15:59:30 +08:00 committed by GitHub
parent 7d1ef09344
commit cfab3e4072
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/querycoordv2/balance/utils.go
View File

@ -45,6 +45,12 @@ func CreateSegmentTasksFromPlans(ctx context.Context, checkerID int64, timeout t
p.ReplicaID,
actions...,
)
log.Info("Create Segment task",
zap.Int64("collection", p.Segment.GetCollectionID()),
zap.Int64("replica", p.ReplicaID),
zap.String("channel", p.Segment.GetInsertChannel()),
zap.Int64("From", p.From),
zap.Int64("To", p.To))
if err != nil {
log.Warn("Create segment task from plan failed",
zap.Int64("collection", p.Segment.GetCollectionID()),
@ -74,6 +80,12 @@ func CreateChannelTasksFromPlans(ctx context.Context, checkerID int64, timeout t
actions = append(actions, action)
}
task, err := task.NewChannelTask(ctx, timeout, checkerID, p.Channel.GetCollectionID(), p.ReplicaID, actions...)
log.Info("Create Channel task",
zap.Int64("collection", p.Channel.GetCollectionID()),
zap.Int64("replica", p.ReplicaID),
zap.String("channel", p.Channel.GetChannelName()),
zap.Int64("From", p.From),
zap.Int64("To", p.To))
if err != nil {
log.Warn("Create channel task from plan failed",
zap.Int64("collection", p.Channel.GetCollectionID()),

1
internal/querycoordv2/task/executor.go
View File

@ -445,6 +445,7 @@ func (ex *Executor) unsubDmChannel(task *ChannelTask, step int) error {
ctx := task.Context()
req := packUnsubDmChannelRequest(task, action)
log.Info("unsubscribe channel...")
status, err := ex.cluster.UnsubDmChannel(ctx, action.Node(), req)
if err != nil {
log.Warn("failed to unsubscribe DmChannel, it may be a false failure", zap.Error(err))