diff --git a/internal/querynode/query_node.go b/internal/querynode/query_node.go index 5a0412e99a00cb9e1bb9c567bbfe5c8582f5c135..2ac65161fed3bd12398b6e2f759615fb6065e666 100644 --- a/internal/querynode/query_node.go +++ b/internal/querynode/query_node.go @@ -290,7 +290,7 @@ func (node *QueryNode) Init() error { node.etcdKV, 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.InitSegcore() @@ -343,7 +343,7 @@ func (node *QueryNode) Start() error { // start services go node.watchChangeInfo() - go node.statsService.start() + //go node.statsService.start() // watch proxy if err := node.initServiceDiscovery(); err != nil { @@ -383,9 +383,9 @@ func (node *QueryNode) Stop() error { if node.queryService != nil { node.queryService.close() } - if node.statsService != nil { - node.statsService.close() - } + //if node.statsService != nil { + // node.statsService.close() + //} node.session.Revoke(time.Second) node.wg.Wait() return nil