test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-02 20:09:57 +08:00
Code Issues Actions 12 Packages Projects Releases Wiki Activity

Remove state service in querynode (#15281)

Browse Source 
Signed-off-by: xige-16 <xi.ge@zilliz.com>
This commit is contained in:
xige-16 2022-01-18 18:43:37 +08:00 committed by GitHub
parent 87394e29b6
commit bbb672cb00
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/querynode/query_node.go
View File

@ -290,7 +290,7 @@ func (node *QueryNode) Init() error {
node.etcdKV, node.etcdKV,
node.msFactory) node.msFactory)
node.statsService = newStatsService(node.queryNodeLoopCtx, node.historical.replica, node.loader.indexLoader.fieldStatsChan, node.msFactory) //node.statsService = newStatsService(node.queryNodeLoopCtx, node.historical.replica, node.loader.indexLoader.fieldStatsChan, node.msFactory)
node.dataSyncService = newDataSyncService(node.queryNodeLoopCtx, streamingReplica, historicalReplica, node.tSafeReplica, node.msFactory) node.dataSyncService = newDataSyncService(node.queryNodeLoopCtx, streamingReplica, historicalReplica, node.tSafeReplica, node.msFactory)
node.InitSegcore() node.InitSegcore()
@ -343,7 +343,7 @@ func (node *QueryNode) Start() error {
// start services // start services
go node.watchChangeInfo() go node.watchChangeInfo()
go node.statsService.start() //go node.statsService.start()
// watch proxy // watch proxy
if err := node.initServiceDiscovery(); err != nil { if err := node.initServiceDiscovery(); err != nil {
@ -383,9 +383,9 @@ func (node *QueryNode) Stop() error {
if node.queryService != nil { if node.queryService != nil {
node.queryService.close() node.queryService.close()
} }
if node.statsService != nil { //if node.statsService != nil {
node.statsService.close() // node.statsService.close()
} //}
node.session.Revoke(time.Second) node.session.Revoke(time.Second)
node.wg.Wait() node.wg.Wait()
return nil return nil