milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove vChannel for collection in historical (#12359) 

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/12402/head
bigsheeper 2021-11-29 20:11:49 +08:00 committed by GitHub
parent 485851597f
commit 65608836e6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/querynode/collection.go
View File

@ -130,6 +130,10 @@ func (c *Collection) removeVChannel(channel Channel) {
}
}
c.vChannels = tmpChannels
log.Debug("remove vChannel from collection",
zap.Any("collectionID", c.ID()),
zap.Any("channel", channel),
)
}
// addPChannels add physical channels to physical channels of collection
@ -237,6 +241,10 @@ func (c *Collection) removeVDeltaChannel(channel Channel) {
}
}
c.vDeltaChannels = tmpChannels
log.Debug("remove vDeltaChannel from collection",
zap.Any("collectionID", c.ID()),
zap.Any("channel", channel),
)
}
// setReleaseTime records when collection is released

2
internal/querynode/task.go
View File

@ -833,6 +833,7 @@ func (r *releasePartitionsTask) Execute(ctx context.Context) error {
return err
}
sCol.removeVChannel(channel)
hCol.removeVChannel(channel)
}
}
}
@ -887,6 +888,7 @@ func (r *releasePartitionsTask) Execute(ctx context.Context) error {
return err
}
sCol.removeVDeltaChannel(channel)
hCol.removeVDeltaChannel(channel)
}
}
}