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 {