From ad293710190ab3d8cfad286ae19b85b73f374095 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Tue, 3 Jun 2025 18:44:31 +0800 Subject: [PATCH] fix: Importing segments stats task must be triggered by import_checker (#42487) issue: #42486 master pr: #42424 Signed-off-by: Cai Zhang --- internal/datacoord/job_manager.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/internal/datacoord/job_manager.go b/internal/datacoord/job_manager.go index 93b596c3a0..6c5faa64f5 100644 --- a/internal/datacoord/job_manager.go +++ b/internal/datacoord/job_manager.go @@ -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 {