Skip to content
Snippets Groups Projects
Commit ba21b11e authored by neza2017's avatar neza2017 Committed by yefu.chen
Browse files

Fix masterservice :drop index


Signed-off-by: default avatarneza2017 <yefu.chen@zilliz.com>
parent 6cdd4d02
No related branches found
No related tags found
No related merge requests found
......@@ -699,14 +699,23 @@ func (t *DropIndexReqTask) IgnoreTimeStamp() bool {
}
func (t *DropIndexReqTask) Execute() error {
dropID, isDropped, err := t.core.MetaTable.DropIndex(t.Req.CollectionName, t.Req.FieldName, t.Req.IndexName)
info, err := t.core.MetaTable.GetIndexByName(t.Req.CollectionName, t.Req.FieldName, t.Req.IndexName)
if err != nil {
log.Warn("GetIndexByName failed,", zap.String("collection name", t.Req.CollectionName), zap.String("field name", t.Req.FieldName), zap.String("index name", t.Req.IndexName), zap.Error(err))
return err
}
if isDropped {
return t.core.DropIndexReq(dropID)
if len(info) == 0 {
return nil
}
return nil
if len(info) != 1 {
return errors.Errorf("len(index) = %d", len(info))
}
err = t.core.DropIndexReq(info[0].IndexID)
if err != nil {
return err
}
_, _, err = t.core.MetaTable.DropIndex(t.Req.CollectionName, t.Req.FieldName, t.Req.IndexName)
return err
}
type CreateIndexTask struct {
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment