Skip to content

Commit e4c1324

Browse files
committed
enable for event loop metric
1 parent 05e24b3 commit e4c1324

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

presto-common/src/main/java/com/facebook/presto/common/RuntimeStats.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,11 @@ public void addMetricValue(String name, RuntimeUnit unit, long value)
9595
metrics.computeIfAbsent(name, k -> new RuntimeMetric(name, unit)).addValue(value);
9696
}
9797

98+
public void addMetricValue(String name, RuntimeUnit unit, long value, boolean trackPercentiles)
99+
{
100+
metrics.computeIfAbsent(name, k -> new RuntimeMetric(name, unit, trackPercentiles)).addValue(value);
101+
}
102+
98103
public void addMetricValueIgnoreZero(String name, RuntimeUnit unit, long value)
99104
{
100105
if (value == 0) {

presto-main-base/src/main/java/com/facebook/presto/execution/StageExecutionStateMachine.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -437,7 +437,7 @@ public void recordTaskUpdateDeliveredTime(long nanos)
437437
@Override
438438
public void recordStartWaitForEventLoop(long nanos)
439439
{
440-
runtimeStats.addMetricValue(TASK_START_WAIT_FOR_EVENT_LOOP, NANO, max(nanos, 0));
440+
runtimeStats.addMetricValue(TASK_START_WAIT_FOR_EVENT_LOOP, NANO, max(nanos, 0), true);
441441
}
442442

443443
public void recordDeliveredUpdates(int updates)

0 commit comments

Comments
 (0)