From f603456b72574a4173b56f4bc99afef506e18c6f Mon Sep 17 00:00:00 2001 From: aoiasd <45024769+aoiasd@users.noreply.github.com> Date: Mon, 17 Apr 2023 10:58:30 +0800 Subject: [PATCH] remove segment from datanode meta when segment dropped (#23398) Signed-off-by: aoiasd --- internal/datanode/flush_manager.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/datanode/flush_manager.go b/internal/datanode/flush_manager.go index 232ea3327a..5b40158e48 100644 --- 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) }