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

Add Err code when task rollback (#17472) 

Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
pull/17475/head
Xiaofan 2022-06-09 21:08:07 +08:00 committed by GitHub
parent 05a918e0ab
commit 66f26943f8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/querycoord/task_scheduler.go
View File

@ -672,7 +672,8 @@ func (scheduler *TaskScheduler) scheduleLoop() {
rollBackTasks := triggerTask.rollBack(scheduler.ctx)
log.Info("scheduleLoop: start rollBack after triggerTask failed",
zap.Int64("triggerTaskID", triggerTask.getTaskID()),
zap.Any("rollBackTasks", rollBackTasks))
zap.Any("rollBackTasks", rollBackTasks),
zap.String("error", resultInfo.Reason))
// there is no need to save rollBacked internal task to etcd
// After queryCoord recover, it will retry failed childTask
// if childTask still execute failed, then reProduce rollBacked tasks