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

Fix rootcoord too frequent useless log (#20044)

Browse Source 
Signed-off-by: longjiquan <jiquan.long@zilliz.com>

Signed-off-by: longjiquan <jiquan.long@zilliz.com>
This commit is contained in:
Jiquan Long 2022-10-25 14:19:30 +08:00 committed by GitHub
parent 377cd210c2
commit 290b902ab0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/rootcoord/step_executor.go
View File

@ -31,13 +31,19 @@ func (s *stepStack) Execute(ctx context.Context) *stepStack {
l := len(steps) l := len(steps)
todo := steps[l-1] todo := steps[l-1]
childSteps, err := todo.Execute(ctx) childSteps, err := todo.Execute(ctx)
// TODO: maybe a interface `step.LogOnError` is better.
_, skipLog := todo.(*waitForTsSyncedStep)
if retry.IsUnRecoverable(err) { if retry.IsUnRecoverable(err) {
log.Warn("failed to execute step, not able to reschedule", zap.Error(err), zap.String("step", todo.Desc())) if !skipLog {
log.Warn("failed to execute step, not able to reschedule", zap.Error(err), zap.String("step", todo.Desc()))
}
return nil return nil
} }
if err != nil { if err != nil {
s.steps = nil // let s can be collected. s.steps = nil // let s can be collected.
log.Warn("failed to execute step, wait for reschedule", zap.Error(err), zap.String("step", todo.Desc())) if !skipLog {
log.Warn("failed to execute step, wait for reschedule", zap.Error(err), zap.String("step", todo.Desc()))
}
return &stepStack{steps: steps} return &stepStack{steps: steps}
} }
// this step is done. // this step is done.