diff --git a/internal/datacoord/task_stats.go b/internal/datacoord/task_stats.go index 6c745602583ad..91ac8df7427f6 100644 --- a/internal/datacoord/task_stats.go +++ b/internal/datacoord/task_stats.go @@ -395,6 +395,9 @@ func (st *statsTask) SetJobInfo(meta *meta) error { return err } + // mark segment compacting false + meta.SetSegmentCompacting(st.segmentID, false) + log.Info("SetJobInfo for stats task success", zap.Int64("taskID", st.taskID), zap.Int64("oldSegmentID", st.segmentID), zap.Int64("targetSegmentID", st.taskInfo.GetSegmentID()), zap.String("subJobType", st.subJobType.String()), zap.String("state", st.taskInfo.GetState().String()))