test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-02 11:59:00 +08:00
Code Issues Actions 12 Packages Projects Releases Wiki Activity

fix: Skip filling segmentID in indexBuildCh to prevent flush blocked (#30747)

Browse Source 
issue: #30580

Signed-off-by: Cai Zhang <cai.zhang@zilliz.com>
This commit is contained in:
cai.zhang 2024-02-22 20:40:53 +08:00 committed by GitHub
parent e2330f02f8
commit 16b4c9a79e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/datacoord/server.go
View File

@ -1044,7 +1044,10 @@ func (s *Server) postFlush(ctx context.Context, segmentID UniqueID) error {
log.Error("flush segment complete failed", zap.Error(err))
return err
}
s.buildIndexCh <- segmentID
select {
case s.buildIndexCh <- segmentID:
default:
}
insertFileNum := 0
for _, fieldBinlog := range segment.GetBinlogs() {

1
internal/datacoord/services.go
View File

@ -468,7 +468,6 @@ func (s *Server) SaveBinlogPaths(ctx context.Context, req *datapb.SaveBinlogPath
zap.Bool("isFlush", req.GetFlushed()),
zap.Bool("isDropped", req.GetDropped()),
zap.Bool("isImport", req.GetImporting()),
zap.Any("startPositions", req.GetStartPositions()),
zap.Any("checkpoints", req.GetCheckPoints()))
// for compatibility issue , if len(channelName) not exist, skip the check