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: Importing segments stats task must be triggered by import_checker (#42487)

Browse Source 
issue: #42486

master pr: #42424

Signed-off-by: Cai Zhang <cai.zhang@zilliz.com>
This commit is contained in:
cai.zhang 2025-06-03 18:44:31 +08:00 committed by GitHub
parent 66e28f605f
commit ad29371019
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
internal/datacoord/job_manager.go
View File

@ -100,8 +100,10 @@ func (jm *statsJobManager) triggerStatsTaskLoop() {
}
func (jm *statsJobManager) triggerSortStatsTask() {
// importing segment must be triggered by import_checker
invisibleSegments := jm.mt.SelectSegments(jm.ctx, SegmentFilterFunc(func(seg *SegmentInfo) bool {
return isFlushed(seg) && seg.GetLevel() != datapb.SegmentLevel_L0 && !seg.GetIsSorted() && seg.GetIsInvisible()
return isFlushed(seg) && seg.GetLevel() != datapb.SegmentLevel_L0 && !seg.GetIsSorted() &&
!seg.GetIsImporting() && seg.GetIsInvisible()
}))
for _, seg := range invisibleSegments {
@ -109,7 +111,8 @@ func (jm *statsJobManager) triggerSortStatsTask() {
}
visibleSegments := jm.mt.SelectSegments(jm.ctx, SegmentFilterFunc(func(seg *SegmentInfo) bool {
return isFlushed(seg) && seg.GetLevel() != datapb.SegmentLevel_L0 && !seg.GetIsSorted() && !seg.GetIsInvisible()
return isFlushed(seg) && seg.GetLevel() != datapb.SegmentLevel_L0 && !seg.GetIsSorted() &&
!seg.GetIsImporting() && !seg.GetIsInvisible()
}))
for _, segment := range visibleSegments {