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

Use path.Join when init ChunkCache path (#27433) 

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/27426/head
yihao.dai 2023-09-30 17:05:27 +08:00 committed by GitHub
parent 63ac43a3b8
commit 7d0dd0047d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/querynodev2/server.go
View File

@ -236,13 +236,13 @@ func (node *QueryNode) InitSegcore() error {
if len(mmapDirPath) == 0 { if len(mmapDirPath) == 0 {
mmapDirPath = paramtable.Get().LocalStorageCfg.Path.GetValue() mmapDirPath = paramtable.Get().LocalStorageCfg.Path.GetValue()
} }
mmapDirPath += "/chunk_cache" chunkCachePath := path.Join(mmapDirPath, "chunk_cache")
policy := paramtable.Get().QueryNodeCfg.ReadAheadPolicy.GetValue() policy := paramtable.Get().QueryNodeCfg.ReadAheadPolicy.GetValue()
err = initcore.InitChunkCache(mmapDirPath, policy) err = initcore.InitChunkCache(chunkCachePath, policy)
if err != nil { if err != nil {
return err return err
} }
log.Info("InitChunkCache done", zap.String("dir", mmapDirPath), zap.String("policy", policy)) log.Info("InitChunkCache done", zap.String("dir", chunkCachePath), zap.String("policy", policy))
initcore.InitTraceConfig(paramtable.Get()) initcore.InitTraceConfig(paramtable.Get())
return nil return nil