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 bug for block clustering compaction (#35019) 

issue: #34703

Signed-off-by: Cai Zhang <cai.zhang@zilliz.com>
pull/34803/head^2
cai.zhang 2024-07-26 11:33:58 +08:00 committed by GitHub
parent 1cff55381d
commit ea13b97b6a
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

@ -714,8 +714,8 @@ func (t *clusteringCompactionTask) backgroundFlush(ctx context.Context) {
if signal.done {
t.doneChan <- struct{}{}
} else if signal.writer == nil {
err = t.flushLargestBuffers(ctx)
t.hasSignal.Store(false)
err = t.flushLargestBuffers(ctx)
} else {
future := t.flushPool.Submit(func() (any, error) {
err := t.flushBinlog(ctx, t.clusterBuffers[signal.id], signal.writer, signal.pack)