From 3d9ec2ab23e5ca0d7c34a797990681cfbac7093a Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Wed, 17 Jul 2024 09:49:42 +0800 Subject: [PATCH] fix: Discard compaction plan when closing dataSyncService (#34737) issue: https://github.com/milvus-io/milvus/issues/34736 --------- Signed-off-by: bigsheeper --- internal/datanode/data_sync_service.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/internal/datanode/data_sync_service.go b/internal/datanode/data_sync_service.go index 91cf033d7f0e3..c21d5ef86ec94 100644 --- 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)