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

fix: Fix data race for clustering compaction (#35435) 

issue: #35436

Signed-off-by: Cai Zhang <cai.zhang@zilliz.com>
pull/35377/head
cai.zhang 2024-08-13 17:10:20 +08:00 committed by GitHub
parent e58d656e65
commit 196b343a94
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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/compaction/clustering_compactor.go
View File

@ -594,7 +594,7 @@ func (t *clusteringCompactionTask) mappingSegment(
if (remained+1)%100 == 0 { if (remained+1)%100 == 0 {
t.clusterBufferLocks.RLock(clusterBuffer.id) t.clusterBufferLocks.RLock(clusterBuffer.id)
currentBufferWriterFull := clusterBuffer.writer.FlushAndIsFull() currentBufferWriterFull := clusterBuffer.writer.IsFull()
t.clusterBufferLocks.RUnlock(clusterBuffer.id) t.clusterBufferLocks.RUnlock(clusterBuffer.id)
currentBufferTotalMemorySize := t.getBufferTotalUsedMemorySize() currentBufferTotalMemorySize := t.getBufferTotalUsedMemorySize()