Optimeize clustering compaction

Signed-off-by: Cai Zhang <[email protected]>
milvus-io · Jun 26, 2024 · 1127a39 · 1127a39
1 parent f8bf690
commit 1127a39
Show file tree

Hide file tree

Showing 3 changed files with 196 additions and 85 deletions.
diff --git a/internal/datacoord/compaction.go b/internal/datacoord/compaction.go
@@ -570,11 +570,12 @@ func (c *compactionPlanHandler) createCompactTask(t *datapb.CompactionTask) (Com
 		}
 	case datapb.CompactionType_ClusteringCompaction:
 		task = &clusteringCompactionTask{
-			CompactionTask:   t,
-			meta:             c.meta,
-			sessions:         c.sessions,
-			handler:          c.handler,
-			analyzeScheduler: c.analyzeScheduler,
+			CompactionTask:      t,
+			meta:                c.meta,
+			sessions:            c.sessions,
+			handler:             c.handler,
+			analyzeScheduler:    c.analyzeScheduler,
+			lastUpdateStateTime: time.Now().UnixMilli(),
 		}
 	default:
 		return nil, merr.WrapErrIllegalCompactionPlan("illegal compaction type")