Skip to content

Commit

Permalink
Fixes the failing test
Browse files Browse the repository at this point in the history
Signed-off-by: Gagan Juneja <[email protected]>
Gagan Juneja committed Jul 23, 2024
1 parent b137a47 commit 6899623
Showing 1 changed file with 7 additions and 5 deletions.
Original file line number Diff line number Diff line change
@@ -218,7 +218,11 @@ private void addResourceTrackingCompletionListener(
}

private void addResourceTrackingCompletionListenerForFetchPhase(
SearchContext searchContext, long fetchStartTime, long fetchTime, String operation, boolean isFailed) {
SearchContext searchContext,
long fetchStartTime,
long fetchTime,
String operation,
boolean isFailed) {
long overallStartTime = fetchStartTime;
long queryTaskId = threadLocal.get().getOrDefault(QUERY_TASK_ID, 0l);
/**
@@ -267,13 +271,11 @@ protected void innerOnResponse(Task task) {
* overall start time.
*/
long totalTime = System.nanoTime() - overallStartTime;
double operationShareFactor =
computeShareFactor(
totalOperationTime, totalTime);
double operationShareFactor = computeShareFactor(totalOperationTime, totalTime);
cpuUtilizationHistogram.record(
Utils.calculateCPUUtilization(
numProcessors,
totalOperationTime,
totalTime,
task.getTotalResourceStats().getCpuTimeInNanos(),
operationShareFactor),
createTags());

0 comments on commit 6899623

Please sign in to comment.