fix: Discard compaction plan when closing dataSyncService (#34737)

issue: #34736 --------- Signed-off-by: bigsheeper <[email protected]>
milvus-io · Jul 17, 2024 · 3d9ec2a · 3d9ec2a
1 parent 8e34c4c
commit 3d9ec2a
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/internal/datanode/data_sync_service.go b/internal/datanode/data_sync_service.go
@@ -117,6 +117,12 @@ func (dsService *dataSyncService) close() {
 			log.Info("dataSyncService flowgraph closed")
 		}
 
+		if dsService.compactor != nil {
+			log.Info("dataSyncService discarding compaction plans")
+			dsService.compactor.discardPlan(dsService.vchannelName)
+			log.Info("dataSyncService compaction plans discarded")
+		}
+
 		dsService.clearGlobalFlushingCache()
 		close(dsService.flushCh)