diff --git a/internal/datacoord/services.go b/internal/datacoord/services.go
index 5ccd439667..b7b7894810 100644
--- a/internal/datacoord/services.go
+++ b/internal/datacoord/services.go
@@ -940,7 +940,7 @@ func (s *Server) GetFlushState(ctx context.Context, req *milvuspb.GetFlushStateR
 	for _, sid := range req.GetSegmentIDs() {
 		segment := s.meta.GetSegment(sid)
 		// segment is nil if it was compacted
-		if segment == nil || segment.GetState() == commonpb.SegmentState_Flushed ||
+		if segment == nil || segment.GetState() == commonpb.SegmentState_Flushing ||
 			segment.GetState() == commonpb.SegmentState_Flushed {
 			continue
 		}