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 {