diff --git a/internal/querynode/shard_cluster.go b/internal/querynode/shard_cluster.go index 151d378965..04e7c26db1 100644 --- a/internal/querynode/shard_cluster.go +++ b/internal/querynode/shard_cluster.go @@ -982,15 +982,7 @@ func (sc *ShardCluster) Search(ctx context.Context, req *querypb.SearchRequest, go func() { defer wg.Done() - queryNode := GetQueryNode() - var partialResult *internalpb.SearchResults - var nodeErr error - - if queryNode != nil && queryNode.IsStandAlone { - partialResult, nodeErr = queryNode.Search(reqCtx, nodeReq) - } else { - partialResult, nodeErr = node.client.Search(reqCtx, nodeReq) - } + partialResult, nodeErr := node.client.Search(reqCtx, nodeReq) resultMut.Lock() defer resultMut.Unlock()