From 6ee6557981545f957a955321f825357a57ea496a Mon Sep 17 00:00:00 2001
From: sunby <bingyi.sun@zilliz.com>
Date: Sun, 7 Feb 2021 14:51:52 +0800
Subject: [PATCH] Record segment flushed state

Signed-off-by: sunby <bingyi.sun@zilliz.com>
---
 internal/dataservice/server.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/dataservice/server.go b/internal/dataservice/server.go
index e1e90cfa8..5b7921267 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
-- 
GitLab