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

[skip e2e] Improve annotation (#14976) 

Signed-off-by: Xieql <qianglong.xie@zilliz.com>
pull/15002/head
Xieql 2022-01-07 13:57:49 +08:00 committed by GitHub
parent 39070ed341
commit 8b06aac7a9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/datanode/flush_manager.go
View File

@ -247,7 +247,7 @@ type rendezvousFlushManager struct {
dropHandler dropHandler dropHandler dropHandler
} }
// getFlushQueue gets or creates a orderFlushQueue for segment id if not found // getFlushQueue gets or creates an orderFlushQueue for segment id if not found
func (m *rendezvousFlushManager) getFlushQueue(segmentID UniqueID) *orderFlushQueue { func (m *rendezvousFlushManager) getFlushQueue(segmentID UniqueID) *orderFlushQueue {
newQueue := newOrderFlushQueue(segmentID, m.notifyFunc) newQueue := newOrderFlushQueue(segmentID, m.notifyFunc)
actual, _ := m.dispatcher.LoadOrStore(segmentID, newQueue) actual, _ := m.dispatcher.LoadOrStore(segmentID, newQueue)