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

Skip record ChannelNotFound error while loading segment (#25669) 

Signed-off-by: yah01 <yang.cen@zilliz.com>
pull/25707/head
yah01 2023-07-18 11:53:18 +08:00 committed by GitHub
parent cc71e065e3
commit 228c0df3f7
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/querycoordv2/task/scheduler.go
View File

@ -26,6 +26,7 @@ import (
"go.uber.org/atomic"
"go.uber.org/zap"
"github.com/cockroachdb/errors"
"github.com/milvus-io/milvus/internal/proto/datapb"
"github.com/milvus-io/milvus/internal/proto/querypb"
"github.com/milvus-io/milvus/internal/querycoordv2/meta"
@ -680,7 +681,7 @@ func (scheduler *taskScheduler) remove(task Task) {
index := NewReplicaSegmentIndex(task)
delete(scheduler.segmentTasks, index)
log = log.With(zap.Int64("segmentID", task.SegmentID()))
if task.Err() != nil {
if task.Err() != nil && !errors.Is(task.Err(), merr.ErrChannelNotFound) {
log.Warn("task scheduler recordSegmentTaskError", zap.Error(task.err))
scheduler.recordSegmentTaskError(task)
}