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

Log language changes in Indexnode (#9692) 

Signed-off-by: NotRyan <ryan.chan@zilliz.com>

Co-authored-by: NotRyan <ryan.chan@zilliz.com>
pull/9774/head
NotRyan 2021-10-12 19:54:33 -07:00 committed by GitHub
parent 54d071b7d6
commit 539fac4f83
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/indexnode/indexnode.go
View File

@ -141,11 +141,11 @@ func (i *IndexNode) Init() error {
}
err := retry.Do(i.loopCtx, connectEtcdFn, retry.Attempts(300))
if err != nil {
log.Error("IndexNode try connect etcd failed", zap.Error(err))
log.Error("IndexNode failed to connect to etcd", zap.Error(err))
initErr = err
return
}
log.Debug("IndexNode connect to etcd successfully")
log.Debug("IndexNode connected to etcd successfully")
option := &miniokv.Option{
Address: Params.MinIOAddress,
@ -164,7 +164,7 @@ func (i *IndexNode) Init() error {
i.kv = kv
log.Debug("IndexNode NewMinIOKV successfully")
log.Debug("IndexNode NewMinIOKV succeeded")
i.closer = trace.InitTracing("index_node")
i.initKnowhere()
@ -269,7 +269,7 @@ func (i *IndexNode) CreateIndex(ctx context.Context, request *indexpb.CreateInde
ret.Reason = err.Error()
return ret, nil
}
log.Info("IndexNode successfully schedule", zap.Int64("indexBuildID", request.IndexBuildID))
log.Info("IndexNode successfully scheduled", zap.Int64("indexBuildID", request.IndexBuildID))
return ret, nil
}

4
internal/indexnode/task_scheduler.go
View File

@ -114,7 +114,7 @@ func (queue *BaseTaskQueue) AddActiveTask(t task) {
tID := t.ID()
_, ok := queue.activeTasks[tID]
if ok {
log.Debug("IndexNode task already in activate task list", zap.Any("TaskID", tID))
log.Debug("IndexNode task already in active task list", zap.Any("TaskID", tID))
}
queue.activeTasks[tID] = t
@ -130,7 +130,7 @@ func (queue *BaseTaskQueue) PopActiveTask(tID UniqueID) task {
delete(queue.activeTasks, tID)
return t
}
log.Debug("IndexNode the task was not found in the active task list", zap.Any("TaskID", tID))
log.Debug("IndexNode task was not found in the active task list", zap.Any("TaskID", tID))
return nil
}