Record segment flushed state

Signed-off-by: sunby <bingyi.sun@zilliz.com>
2021-02-07 14:51:52 +08:00 · 2021-02-07 14:51:52 +08:00 · 6ee6557981
parent eba5b9ae27
commit 6ee6557981
1 changed files with 1 additions and 0 deletions
--- 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