Skip to content

Commit 112a611

Browse files
committed
handle failed requests metrics in query insights
Signed-off-by: Chenyang Ji <[email protected]>
1 parent 4d9ac85 commit 112a611

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

plugins/query-insights/src/main/java/org/opensearch/plugin/insights/core/listener/QueryInsightsListener.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,14 @@ public void onRequestStart(SearchRequestContext searchRequestContext) {}
173173

174174
@Override
175175
public void onRequestEnd(final SearchPhaseContext context, final SearchRequestContext searchRequestContext) {
176+
constructSearchQueryRecord(context, searchRequestContext);
177+
}
178+
@Override
179+
public void onRequestFailure(final SearchPhaseContext context, final SearchRequestContext searchRequestContext) {
180+
constructSearchQueryRecord(context, searchRequestContext);
181+
}
182+
183+
private void constructSearchQueryRecord(final SearchPhaseContext context, final SearchRequestContext searchRequestContext) {
176184
SearchTask searchTask = context.getTask();
177185
List<TaskResourceInfo> tasksResourceUsages = searchRequestContext.getPhaseResourceUsage();
178186
tasksResourceUsages.add(
@@ -228,4 +236,5 @@ public void onRequestEnd(final SearchPhaseContext context, final SearchRequestCo
228236
log.error(String.format(Locale.ROOT, "fail to ingest query insight data, error: %s", e));
229237
}
230238
}
239+
231240
}

0 commit comments

Comments
 (0)