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

Fix querycoord cannot update deltaChannel info (#17901)

Browse Source 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia 2022-06-29 15:38:17 +08:00 committed by GitHub
parent 7915175638
commit 106f19a7b8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/querycoord/meta.go
View File

@ -928,12 +928,6 @@ func (m *MetaReplica) setDeltaChannel(collectionID UniqueID, infos []*datapb.Vch
return err return err
} }
_, ok := m.deltaChannelInfos[collectionID]
if ok {
log.Debug("delta channel already exist", zap.Any("collectionID", collectionID))
return nil
}
err := saveDeltaChannelInfo(collectionID, infos, m.getKvClient()) err := saveDeltaChannelInfo(collectionID, infos, m.getKvClient())
if err != nil { if err != nil {
log.Error("save delta channel info error", zap.Int64("collectionID", collectionID), zap.Error(err)) log.Error("save delta channel info error", zap.Int64("collectionID", collectionID), zap.Error(err))