From 9a42cff9b47a0424bcb45e4998b501b44a1059b9 Mon Sep 17 00:00:00 2001 From: "cai.zhang" Date: Thu, 1 Dec 2022 16:35:20 +0800 Subject: [PATCH] GetFlushedSegments should include flushing segment (#20859) Signed-off-by: cai.zhang Signed-off-by: cai.zhang --- internal/datacoord/services.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/datacoord/services.go b/internal/datacoord/services.go index f2467fbca4..a4d24153c0 100644 --- a/internal/datacoord/services.go +++ b/internal/datacoord/services.go @@ -754,7 +754,8 @@ func (s *Server) GetFlushedSegments(ctx context.Context, req *datapb.GetFlushedS // if this segment == nil, we assume this segment has been gc if segment == nil || (segment.GetState() != commonpb.SegmentState_Dropped && - segment.GetState() != commonpb.SegmentState_Flushed) { + segment.GetState() != commonpb.SegmentState_Flushed && + segment.GetState() != commonpb.SegmentState_Flushing) { continue } if !req.GetIncludeUnhealthy() && segment.GetState() == commonpb.SegmentState_Dropped {