From a529410b3870f10de5142aeb8d2cd75671f6166e Mon Sep 17 00:00:00 2001 From: sunby Date: Wed, 23 Jun 2021 12:20:06 +0800 Subject: [PATCH] Fix data race in internal/datacoord/meta.go (#6005) Signed-off-by: sunby --- internal/datacoord/meta.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/datacoord/meta.go b/internal/datacoord/meta.go index 792141a57c..7c46a1c507 100644 --- a/internal/datacoord/meta.go +++ b/internal/datacoord/meta.go @@ -345,6 +345,8 @@ func (m *meta) SaveBinlogAndCheckPoints(segID UniqueID, flushed bool, } func (m *meta) GetSegmentsByChannel(dmlCh string) []*datapb.SegmentInfo { + m.RLock() + defer m.RUnlock() infos := make([]*datapb.SegmentInfo, 0) for _, segment := range m.segments { if segment.InsertChannel != dmlCh {