mirror of
https://gitee.com/milvus-io/milvus.git
synced 2026-01-07 19:31:51 +08:00
Allow flushed segments trigger flushe process (#10539)
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
parent
fb7d1271a4
commit
bd90a3831c
@ -494,7 +494,7 @@ func (node *DataNode) getChannelNamebySegmentID(segID UniqueID) string {
|
||||
node.chanMut.RLock()
|
||||
defer node.chanMut.RUnlock()
|
||||
for name, dataSync := range node.vchan2SyncService {
|
||||
if dataSync.replica.hasSegment(segID, false) {
|
||||
if dataSync.replica.hasSegment(segID, true) {
|
||||
return name
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user