admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-02-02 01:06:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: [cherry-pick] Fix bug for block clustering compaction (#35021)

Browse Source 
issue: #34703 

master pr: #35019

Signed-off-by: Cai Zhang <cai.zhang@zilliz.com>
This commit is contained in:
cai.zhang 2024-07-26 11:33:40 +08:00 committed by GitHub
parent 6f0f3034c6
commit 9cd6dbcbc9
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

@ -711,8 +711,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)