未验证 提交 34833680 编写于 作者: C congqixia 提交者: GitHub

Add lock before query release collection from replica (#16880)

Signed-off-by: NCongqi Xia <congqi.xia@zilliz.com>
上级 216c45fb
......@@ -723,6 +723,9 @@ func (r *releaseCollectionTask) Execute(ctx context.Context) error {
}
func (r *releaseCollectionTask) releaseReplica(replica ReplicaInterface, replicaType ReplicaType) error {
// block search/query operation
replica.queryLock()
collection, err := replica.getCollectionByID(r.req.CollectionID)
if err != nil {
return err
......@@ -730,6 +733,7 @@ func (r *releaseCollectionTask) releaseReplica(replica ReplicaInterface, replica
// set release time
log.Info("set release time", zap.Any("collectionID", r.req.CollectionID))
collection.setReleaseTime(r.req.Base.Timestamp)
replica.queryUnlock()
// remove all flow graphs of the target collection
var channels []Channel
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册