Profile API
editProfile API
editThe Profile API is a debugging tool and adds significant overhead to search execution.
Provides detailed timing information about the execution of individual components in a search request.
Description
editThe Profile API gives the user insight into how search requests are executed at a low level so that the user can understand why certain requests are slow, and take steps to improve them. Note that the Profile API, amongst other things, doesn’t measure network latency, time spent in the search fetch phase, time spent while the requests spends in queues or while merging shard responses on the coordinating node.
The output from the Profile API is very verbose, especially for complicated requests executed across many shards. Pretty-printing the response is recommended to help understand the output.
Examples
editAny _search
request can be profiled by adding a top-level profile
parameter:
GET /my-index-000001/_search { "profile": true, "query" : { "match" : { "message" : "GET /search" } } }
The API returns the following result:
{ "took": 25, "timed_out": false, "_shards": { "total": 1, "successful": 1, "skipped": 0, "failed": 0 }, "hits": { "total": { "value": 5, "relation": "eq" }, "max_score": 0.17402273, "hits": [...] }, "profile": { "shards": [ { "id": "[2aE02wS1R8q_QFnYu6vDVQ][my-index-000001][0]", "searches": [ { "query": [ { "type": "BooleanQuery", "description": "message:get message:search", "time_in_nanos" : 11972972, "breakdown" : { "set_min_competitive_score_count": 0, "match_count": 5, "shallow_advance_count": 0, "set_min_competitive_score": 0, "next_doc": 39022, "match": 4456, "next_doc_count": 5, "score_count": 5, "compute_max_score_count": 0, "compute_max_score": 0, "advance": 84525, "advance_count": 1, "score": 37779, "build_scorer_count": 2, "create_weight": 4694895, "shallow_advance": 0, "create_weight_count": 1, "build_scorer": 7112295 }, "children": [ { "type": "TermQuery", "description": "message:get", "time_in_nanos": 3801935, "breakdown": { "set_min_competitive_score_count": 0, "match_count": 0, "shallow_advance_count": 3, "set_min_competitive_score": 0, "next_doc": 0, "match": 0, "next_doc_count": 0, "score_count": 5, "compute_max_score_count": 3, "compute_max_score": 32487, "advance": 5749, "advance_count": 6, "score": 16219, "build_scorer_count": 3, "create_weight": 2382719, "shallow_advance": 9754, "create_weight_count": 1, "build_scorer": 1355007 } }, { "type": "TermQuery", "description": "message:search", "time_in_nanos": 205654, "breakdown": { "set_min_competitive_score_count": 0, "match_count": 0, "shallow_advance_count": 3, "set_min_competitive_score": 0, "next_doc": 0, "match": 0, "next_doc_count": 0, "score_count": 5, "compute_max_score_count": 3, "compute_max_score": 6678, "advance": 12733, "advance_count": 6, "score": 6627, "build_scorer_count": 3, "create_weight": 130951, "shallow_advance": 2512, "create_weight_count": 1, "build_scorer": 46153 } } ] } ], "rewrite_time": 451233, "collector": [ { "name": "SimpleTopScoreDocCollector", "reason": "search_top_hits", "time_in_nanos": 775274 } ] } ], "aggregations": [] } ] } }
Even for a simple query, the response is relatively complicated. Let’s break it down piece-by-piece before moving to more complex examples.
The overall structure of the profile response is as follows:
{ "profile": { "shards": [ { "id": "[2aE02wS1R8q_QFnYu6vDVQ][my-index-000001][0]", "searches": [ { "query": [...], "rewrite_time": 51443, "collector": [...] } ], "aggregations": [...] } ] } }
A profile is returned for each shard that participated in the response, and is identified by a unique ID. |
|
Each profile contains a section which holds details about the query execution. |
|
Each profile has a single time representing the cumulative rewrite time. |
|
Each profile also contains a section about the Lucene Collectors which run the search. |
|
Each profile contains a section which holds the details about the aggregation execution. |
Because a search request may be executed against one or more shards in an index,
and a search may cover one or more indices, the top level element in the profile
response is an array of shard
objects. Each shard object lists its id
which
uniquely identifies the shard. The ID’s format is
[nodeID][indexName][shardID]
.
The profile itself may consist of one or more "searches", where a search is a
query executed against the underlying Lucene index. Most search requests
submitted by the user will only execute a single search
against the Lucene
index. But occasionally multiple searches will be executed, such as including a
global aggregation (which needs to execute a secondary "match_all" query for the
global context).
Inside each search
object there will be two arrays of profiled information:
a query
array and a collector
array. Alongside the search
object is an
aggregations
object that contains the profile information for the
aggregations. In the future, more sections may be added, such as suggest
,
highlight
, etc.
There will also be a rewrite
metric showing the total time spent rewriting the
query (in nanoseconds).
As with other statistics apis, the Profile API supports human readable outputs. This can be turned on by adding
?human=true
to the query string. In this case, the output contains the additional time
field containing rounded,
human readable timing information (e.g. "time": "391,9ms"
, "time": "123.3micros"
).
Profiling Queries
editThe details provided by the Profile API directly expose Lucene class names and concepts, which means that complete interpretation of the results require fairly advanced knowledge of Lucene. This page attempts to give a crash-course in how Lucene executes queries so that you can use the Profile API to successfully diagnose and debug queries, but it is only an overview. For complete understanding, please refer to Lucene’s documentation and, in places, the code.
With that said, a complete understanding is often not required to fix a slow query. It is usually
sufficient to see that a particular component of a query is slow, and not necessarily understand why
the advance
phase of that query is the cause, for example.
query
Section
editThe query
section contains detailed timing of the query tree executed by
Lucene on a particular shard. The overall structure of this query tree will
resemble your original Elasticsearch query, but may be slightly (or sometimes
very) different. It will also use similar but not always identical naming.
Using our previous match
query example, let’s analyze the query
section:
"query": [ { "type": "BooleanQuery", "description": "message:get message:search", "time_in_nanos": "11972972", "breakdown": {...}, "children": [ { "type": "TermQuery", "description": "message:get", "time_in_nanos": "3801935", "breakdown": {...} }, { "type": "TermQuery", "description": "message:search", "time_in_nanos": "205654", "breakdown": {...} } ] } ]
Based on the profile structure, we can see that our match
query was rewritten
by Lucene into a BooleanQuery with two clauses (both holding a TermQuery). The
type
field displays the Lucene class name, and often aligns with the
equivalent name in Elasticsearch. The description
field displays the Lucene
explanation text for the query, and is made available to help differentiating
between parts of your query (e.g. both message:get
and message:search
are
TermQuery’s and would appear identical otherwise.
The time_in_nanos
field shows that this query took ~11.9ms for the entire
BooleanQuery to execute. The recorded time is inclusive of all children.
The breakdown
field will give detailed stats about how the time was spent,
we’ll look at that in a moment. Finally, the children
array lists any
sub-queries that may be present. Because we searched for two values ("get
search"), our BooleanQuery holds two children TermQueries. They have identical
information (type, time, breakdown, etc). Children are allowed to have their
own children.
Timing Breakdown
editThe breakdown
component lists detailed timing statistics about low-level
Lucene execution:
"breakdown": { "set_min_competitive_score_count": 0, "match_count": 5, "shallow_advance_count": 0, "set_min_competitive_score": 0, "next_doc": 39022, "match": 4456, "next_doc_count": 5, "score_count": 5, "compute_max_score_count": 0, "compute_max_score": 0, "advance": 84525, "advance_count": 1, "score": 37779, "build_scorer_count": 2, "create_weight": 4694895, "shallow_advance": 0, "create_weight_count": 1, "build_scorer": 7112295 }
Timings are listed in wall-clock nanoseconds and are not normalized at all. All
caveats about the overall time_in_nanos
apply here. The intention of the
breakdown is to give you a feel for A) what machinery in Lucene is actually
eating time, and B) the magnitude of differences in times between the various
components. Like the overall time, the breakdown is inclusive of all children
times.
The meaning of the stats are as follows:
All parameters:
edit
|
A Query in Lucene must be capable of reuse across multiple IndexSearchers (think of it as the engine that
executes a search against a specific Lucene Index). This puts Lucene in a tricky spot, since many queries
need to accumulate temporary state/statistics associated with the index it is being used against, but the
Query contract mandates that it must be immutable.
|
|
This parameter shows how long it takes to build a Scorer for the query. A Scorer is the mechanism that
iterates over matching documents and generates a score per-document (e.g. how well does "foo" match the document?).
Note, this records the time required to generate the Scorer object, not actually score the documents. Some
queries have faster or slower initialization of the Scorer, depending on optimizations, complexity, etc.
|
|
The Lucene method |
|
|
|
Some queries, such as phrase queries, match documents using a "two-phase" process. First, the document is
"approximately" matched, and if it matches approximately, it is checked a second time with a more rigorous
(and expensive) process. The second phase verification is what the |
|
This records the time taken to score a particular document via its Scorer |
|
Records the number of invocations of the particular method. For example, |
collectors
Section
editThe Collectors portion of the response shows high-level execution details. Lucene works by defining a "Collector" which is responsible for coordinating the traversal, scoring, and collection of matching documents. Collectors are also how a single query can record aggregation results, execute unscoped "global" queries, execute post-query filters, etc.
Looking at the previous example:
"collector": [ { "name": "SimpleTopScoreDocCollector", "reason": "search_top_hits", "time_in_nanos": 775274 } ]
We see a single collector named SimpleTopScoreDocCollector
wrapped into
CancellableCollector
. SimpleTopScoreDocCollector
is the default "scoring and
sorting" Collector
used by Elasticsearch. The reason
field attempts to give a plain
English description of the class name. The time_in_nanos
is similar to the
time in the Query tree: a wall-clock time inclusive of all children. Similarly,
children
lists all sub-collectors. The CancellableCollector
that wraps
SimpleTopScoreDocCollector
is used by Elasticsearch to detect if the current search was
cancelled and stop collecting documents as soon as it occurs.
It should be noted that Collector times are independent from the Query times. They are calculated, combined, and normalized independently! Due to the nature of Lucene’s execution, it is impossible to "merge" the times from the Collectors into the Query section, so they are displayed in separate portions.
For reference, the various collector reasons are:
|
A collector that scores and sorts documents. This is the most common collector and will be seen in most simple searches |
|
A collector that only counts the number of documents that match the query, but does not fetch the source.
This is seen when |
|
A collector that terminates search execution after |
|
A collector that only returns matching documents that have a score greater than |
|
A collector that wraps several other collectors. This is seen when combinations of search, aggregations, global aggs, and post_filters are combined in a single search. |
|
A collector that halts execution after a specified period of time. This is seen when a |
|
A collector that Elasticsearch uses to run aggregations against the query scope. A single |
|
A collector that executes an aggregation against the global query scope, rather than the specified query. Because the global scope is necessarily different from the executed query, it must execute its own match_all query (which you will see added to the Query section) to collect your entire dataset |
rewrite
Section
editAll queries in Lucene undergo a "rewriting" process. A query (and its sub-queries) may be rewritten one or more times, and the process continues until the query stops changing. This process allows Lucene to perform optimizations, such as removing redundant clauses, replacing one query for a more efficient execution path, etc. For example a Boolean → Boolean → TermQuery can be rewritten to a TermQuery, because all the Booleans are unnecessary in this case.
The rewriting process is complex and difficult to display, since queries can change drastically. Rather than showing the intermediate results, the total rewrite time is simply displayed as a value (in nanoseconds). This value is cumulative and contains the total time for all queries being rewritten.
A more complex example
editTo demonstrate a slightly more complex query and the associated results, we can profile the following query:
GET /my-index-000001/_search { "profile": true, "query": { "term": { "user.id": { "value": "elkbee" } } }, "aggs": { "my_scoped_agg": { "terms": { "field": "http.response.status_code" } }, "my_global_agg": { "global": {}, "aggs": { "my_level_agg": { "terms": { "field": "http.response.status_code" } } } } }, "post_filter": { "match": { "message": "search" } } }
This example has:
- A query
- A scoped aggregation
- A global aggregation
- A post_filter
The API returns the following result:
{ ... "profile": { "shards": [ { "id": "[P6-vulHtQRWuD4YnubWb7A][my-index-000001][0]", "searches": [ { "query": [ { "type": "TermQuery", "description": "message:search", "time_in_nanos": 141618, "breakdown": { "set_min_competitive_score_count": 0, "match_count": 0, "shallow_advance_count": 0, "set_min_competitive_score": 0, "next_doc": 0, "match": 0, "next_doc_count": 0, "score_count": 0, "compute_max_score_count": 0, "compute_max_score": 0, "advance": 3942, "advance_count": 4, "score": 0, "build_scorer_count": 2, "create_weight": 38380, "shallow_advance": 0, "create_weight_count": 1, "build_scorer": 99296 } }, { "type": "TermQuery", "description": "user.id:elkbee", "time_in_nanos": 163081, "breakdown": { "set_min_competitive_score_count": 0, "match_count": 0, "shallow_advance_count": 0, "set_min_competitive_score": 0, "next_doc": 2447, "match": 0, "next_doc_count": 4, "score_count": 4, "compute_max_score_count": 0, "compute_max_score": 0, "advance": 3552, "advance_count": 1, "score": 5027, "build_scorer_count": 2, "create_weight": 107840, "shallow_advance": 0, "create_weight_count": 1, "build_scorer": 44215 } } ], "rewrite_time": 4769, "collector": [ { "name": "MultiCollector", "reason": "search_multi", "time_in_nanos": 1945072, "children": [ { "name": "FilteredCollector", "reason": "search_post_filter", "time_in_nanos": 500850, "children": [ { "name": "SimpleTopScoreDocCollector", "reason": "search_top_hits", "time_in_nanos": 22577 } ] }, { "name": "MultiBucketCollector: [[my_scoped_agg, my_global_agg]]", "reason": "aggregation", "time_in_nanos": 867617 } ] } ] } ], "aggregations": [...] } ] } }
As you can see, the output is significantly more verbose than before. All the major portions of the query are represented:
-
The first
TermQuery
(user.id:elkbee) represents the mainterm
query. -
The second
TermQuery
(message:search) represents thepost_filter
query.
The Collector tree is fairly straightforward, showing how a single CancellableCollector wraps a MultiCollector which also wraps a FilteredCollector to execute the post_filter (and in turn wraps the normal scoring SimpleCollector), a BucketCollector to run all scoped aggregations.
Understanding MultiTermQuery output
editA special note needs to be made about the MultiTermQuery
class of queries.
This includes wildcards, regex, and fuzzy queries. These queries emit very
verbose responses, and are not overly structured.
Essentially, these queries rewrite themselves on a per-segment basis. If you
imagine the wildcard query b*
, it technically can match any token that begins
with the letter "b". It would be impossible to enumerate all possible
combinations, so Lucene rewrites the query in context of the segment being
evaluated, e.g., one segment may contain the tokens [bar, baz]
, so the query
rewrites to a BooleanQuery combination of "bar" and "baz". Another segment may
only have the token [bakery]
, so the query rewrites to a single TermQuery for
"bakery".
Due to this dynamic, per-segment rewriting, the clean tree structure becomes distorted and no longer follows a clean "lineage" showing how one query rewrites into the next. At present time, all we can do is apologize, and suggest you collapse the details for that query’s children if it is too confusing. Luckily, all the timing statistics are correct, just not the physical layout in the response, so it is sufficient to just analyze the top-level MultiTermQuery and ignore its children if you find the details too tricky to interpret.
Hopefully this will be fixed in future iterations, but it is a tricky problem to solve and still in-progress. :)
Profiling Aggregations
editaggregations
Section
editThe aggregations
section contains detailed timing of the aggregation tree
executed by a particular shard. The overall structure of this aggregation tree
will resemble your original Elasticsearch request. Let’s execute the previous query again
and look at the aggregation profile this time:
GET /my-index-000001/_search { "profile": true, "query": { "term": { "user.id": { "value": "elkbee" } } }, "aggs": { "my_scoped_agg": { "terms": { "field": "http.response.status_code" } }, "my_global_agg": { "global": {}, "aggs": { "my_level_agg": { "terms": { "field": "http.response.status_code" } } } } }, "post_filter": { "match": { "message": "search" } } }
This yields the following aggregation profile output:
{ "profile": { "shards": [ { "aggregations": [ { "type": "NumericTermsAggregator", "description": "my_scoped_agg", "time_in_nanos": 79294, "breakdown": { "reduce": 0, "build_aggregation": 30885, "build_aggregation_count": 1, "initialize": 2623, "initialize_count": 1, "reduce_count": 0, "collect": 45786, "collect_count": 4 }, "debug": { "total_buckets": 1, "result_strategy": "long_terms" } }, { "type": "GlobalAggregator", "description": "my_global_agg", "time_in_nanos": 104325, "breakdown": { "reduce": 0, "build_aggregation": 22470, "build_aggregation_count": 1, "initialize": 12454, "initialize_count": 1, "reduce_count": 0, "collect": 69401, "collect_count": 4 }, "children": [ { "type": "NumericTermsAggregator", "description": "my_level_agg", "time_in_nanos": 76876, "breakdown": { "reduce": 0, "build_aggregation": 13824, "build_aggregation_count": 1, "initialize": 1441, "initialize_count": 1, "reduce_count": 0, "collect": 61611, "collect_count": 4 }, "debug": { "total_buckets": 1, "result_strategy": "long_terms" } } ] } ] } ] } }
From the profile structure we can see that the my_scoped_agg
is internally
being run as a NumericTermsAggregator
(because the field it is aggregating,
http.response.status_code
, is a numeric field). At the same level, we see a GlobalAggregator
which comes from my_global_agg
. That aggregation then has a child
NumericTermsAggregator
which comes from the second term’s aggregation on http.response.status_code
.
The time_in_nanos
field shows the time executed by each aggregation, and is
inclusive of all children. While the overall time is useful, the breakdown
field will give detailed stats about how the time was spent.
Some aggregations may return expert debug
information that describe features
of the underlying execution of the aggregation that are 'useful for folks that
hack on aggregations but that we don’t expect to be otherwise useful. They can
vary wildly between versions, aggregations, and aggregation execution
strategies.
Timing Breakdown
editThe breakdown
component lists detailed statistics about low-level execution:
"breakdown": { "reduce": 0, "build_aggregation": 30885, "build_aggregation_count": 1, "initialize": 2623, "initialize_count": 1, "reduce_count": 0, "collect": 45786, "collect_count": 4 }
Timings are listed in wall-clock nanoseconds and are not normalized at all. All
caveats about the overall time
apply here. The intention of the breakdown is
to give you a feel for A) what machinery in Elasticsearch is actually eating time, and B)
the magnitude of differences in times between the various components. Like the
overall time, the breakdown is inclusive of all children times.
The meaning of the stats are as follows:
All parameters:
edit
|
This times how long it takes to create and initialise the aggregation before starting to collect documents. |
|
This represents the cumulative time spent in the collect phase of the aggregation. This is where matching documents are passed to the aggregation and the state of the aggregator is updated based on the information contained in the documents. |
|
This represents the time spent creating the shard level results of the aggregation ready to pass back to the reducing node after the collection of documents is finished. |
|
This is not currently used and will always report |
|
Records the number of invocations of the particular method. For example, |
Profiling Considerations
editLike any profiler, the Profile API introduces a non-negligible overhead to
search execution. The act of instrumenting low-level method calls such as
collect
, advance
, and next_doc
can be fairly expensive, since these
methods are called in tight loops. Therefore, profiling should not be enabled
in production settings by default, and should not be compared against
non-profiled query times. Profiling is just a diagnostic tool.
There are also cases where special Lucene optimizations are disabled, since they are not amenable to profiling. This could cause some queries to report larger relative times than their non-profiled counterparts, but in general should not have a drastic effect compared to other components in the profiled query.
Limitations
edit- Profiling currently does not measure the search fetch phase nor the network overhead.
- Profiling also does not account for time spent in the queue, merging shard responses on the coordinating node, or additional work such as building global ordinals (an internal data structure used to speed up search).
-
Profiling statistics are currently not available for suggestions,
highlighting,
dfs_query_then_fetch
. - Profiling of the reduce phase of aggregation is currently not available.
- The Profiler is still highly experimental. The Profiler is instrumenting parts of Lucene that were never designed to be exposed in this manner, and so all results should be viewed as a best effort to provide detailed diagnostics. We hope to improve this over time. If you find obviously wrong numbers, strange query structures, or other bugs, please report them!