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

Fix delete failed in query node (#12302)

Browse Source 
Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
This commit is contained in:
bigsheeper 2021-11-26 16:15:16 +08:00 committed by GitHub
parent b6d0150dc5
commit dbcb153687
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/querynode/tsafe.go
View File

@ -20,6 +20,7 @@ import (
"go.uber.org/zap" "go.uber.org/zap"
"github.com/milvus-io/milvus/internal/log" "github.com/milvus-io/milvus/internal/log"
"github.com/milvus-io/milvus/internal/util/typeutil"
) )
type tSafeWatcher struct { type tSafeWatcher struct {
@ -85,7 +86,7 @@ func newTSafe(ctx context.Context, channel Channel) tSafer {
watcherList: make([]*tSafeWatcher, 0), watcherList: make([]*tSafeWatcher, 0),
tSafeChan: make(chan tSafeMsg, channelSize), tSafeChan: make(chan tSafeMsg, channelSize),
tSafeRecord: make(map[UniqueID]Timestamp), tSafeRecord: make(map[UniqueID]Timestamp),
tSafe: math.MaxUint64, tSafe: typeutil.ZeroTimestamp,
} }
return t return t
} }

3
internal/querynode/tsafe_replica.go
View File

@ -146,8 +146,7 @@ func (t *tSafeReplica) registerTSafeWatcher(vChannel Channel, watcher *tSafeWatc
if err != nil { if err != nil {
return err return err
} }
safer.registerTSafeWatcher(watcher) return safer.registerTSafeWatcher(watcher)
return nil
} }
func newTSafeReplica() TSafeReplicaInterface { func newTSafeReplica() TSafeReplicaInterface {