remove segment from datanode meta when segment dropped (#23398)

Signed-off-by: N aoiasd <zhicheng.yue@zilliz.com>

remove segment from datanode meta when segment dropped (#23398)
Signed-off-by: N aoiasd <zhicheng.yue@zilliz.com>
f603456b · aoiasd · GitHub · 7ff6a3a2 · f603456b
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

internal/datanode/flush_manager.go internal/datanode/flush_manager.go +3 -1

未找到文件。
--- a/internal/datanode/flush_manager.go
+++ b/internal/datanode/flush_manager.go
@@ -854,7 +854,9 @@ func flushNotifyFunc(dsService *dataSyncService, opts ...retry.Option) notifyMet
 			// TODO change to graceful stop
 			panic(err)
 		}
-		if pack.flushed || pack.dropped {
+		if pack.dropped {
+			dsService.channel.removeSegments(pack.segmentID)
+		} else if pack.flushed {
 			dsService.channel.segmentFlushed(pack.segmentID)
 		}