enhance: bm25 stats local cache use local storage path (#42923)

Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>
This commit is contained in:
aoiasd 2025-06-25 13:44:46 +08:00 committed by GitHub
parent 0dfe5308e1
commit e2566c0e92
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 1 additions and 11 deletions

View File

@ -544,7 +544,6 @@ queryNode:
size: 10 # the size for worker querynode client pool
idfOracle:
enableDisk: true
localPath: /var/lib/milvus/bm25_logs
writeConcurrency: 4
ip: # TCP/IP address of queryNode. If not specified, use the first unicastable address
port: 21123 # TCP port of queryNode

View File

@ -404,7 +404,7 @@ func (o *idfOracle) syncloop() {
func (o *idfOracle) localloop() {
pool := conc.NewPool[struct{}](paramtable.Get().QueryNodeCfg.IDFWriteConcurrenct.GetAsInt())
o.dirPath = path.Join(paramtable.Get().QueryNodeCfg.IDFLocalPath.GetValue(), fmt.Sprintf("%d", o.collectionID))
o.dirPath = path.Join(paramtable.Get().LocalStorageCfg.Path.GetValue(), "bm25", fmt.Sprintf("%d", o.collectionID))
defer o.wg.Done()
for {

View File

@ -2896,7 +2896,6 @@ type queryNodeConfig struct {
// Idf Oracle
IDFEnableDisk ParamItem `refreshable:"true"`
IDFLocalPath ParamItem `refreshable:"true"`
IDFWriteConcurrenct ParamItem `refreshable:"true"`
// partial search
PartialResultRequiredDataRatio ParamItem `refreshable:"true"`
@ -2911,14 +2910,6 @@ func (p *queryNodeConfig) init(base *BaseTable) {
}
p.IDFEnableDisk.Init(base.mgr)
p.IDFLocalPath = ParamItem{
Key: "queryNode.idfOracle.localPath",
Version: "2.6.0",
Export: true,
DefaultValue: "/var/lib/milvus/bm25_logs",
}
p.IDFLocalPath.Init(base.mgr)
p.IDFWriteConcurrenct = ParamItem{
Key: "queryNode.idfOracle.writeConcurrency",
Version: "2.6.0",