enhance: [cherry-pick] Skip updating the level that are already at th…

…e specified level (#35093)

issue: #34495 

master pr: #35094

Signed-off-by: Cai Zhang <cai.zhang@zilliz.com>

internal/datacoord/compaction_task_clustering.go

@@ -189,6 +189,10 @@ func (t *clusteringCompactionTask) BuildCompactionRequest() (*datapb.CompactionP
 
 func (t *clusteringCompactionTask) processPipelining() error {
 	log := log.With(zap.Int64("triggerID", t.TriggerID), zap.Int64("collectionID", t.GetCollectionID()), zap.Int64("planID", t.GetPlanID()))
+	if t.NeedReAssignNodeID() {
+		log.Debug("wait for the node to be assigned before proceeding with the subsequent steps")
+		return nil
+	}
 	var operators []UpdateOperator
 	for _, segID := range t.InputSegments {
 		operators = append(operators, UpdateSegmentLevelOperator(segID, datapb.SegmentLevel_L2))

internal/datacoord/meta.go

@@ -788,6 +788,10 @@ func UpdateSegmentLevelOperator(segmentID int64, level datapb.SegmentLevel) Upda
 				zap.Int64("segmentID", segmentID))
 			return false
 		}
+		if segment.LastLevel == segment.Level && segment.Level == level {
+			log.Debug("segment already is this level", zap.Int64("segID", segmentID), zap.String("level", level.String()))
+			return true
+		}
 		segment.LastLevel = segment.Level
 		segment.Level = level
 		return true