diff --git a/internal/dataservice/server.go b/internal/dataservice/server.go
index e1e90cfa834fc9936825dac50df9f63f4c4d4b49..5b792126798a4271e534e1967fb87dd4a3644580 100644
--- a/internal/dataservice/server.go
+++ b/internal/dataservice/server.go
@@ -359,6 +359,7 @@ func (s *Server) startSegmentFlushChannel(ctx context.Context) {
 				continue
 			}
 			segmentInfo.FlushedTime = realMsg.BeginTimestamp
+			segmentInfo.State = commonpb.SegmentState_SegmentFlushed
 			if err = s.meta.UpdateSegment(segmentInfo); err != nil {
 				log.Println(err.Error())
 				continue