diff --git a/internal/querynode/query_node.go b/internal/querynode/query_node.go index c8006d7362..6522e71ba2 100644 --- a/internal/querynode/query_node.go +++ b/internal/querynode/query_node.go @@ -397,23 +397,19 @@ func (node *QueryNode) Stop() error { if node.dataSyncService != nil { node.dataSyncService.close() } - if node.historical != nil { - node.historical.close() - } + + // release streaming first for query/search holds query lock in streaming collection if node.streaming != nil { node.streaming.close() } - /* - if node.queryService != nil { - node.queryService.close() - }*/ + if node.historical != nil { + node.historical.close() + } if node.queryShardService != nil { node.queryShardService.close() } - //if node.statsService != nil { - // node.statsService.close() - //} + node.session.Revoke(time.Second) node.wg.Wait() return nil