From 71b01e53ba0987027c82666080700839bd656671 Mon Sep 17 00:00:00 2001 From: Denis Loginov Date: Fri, 17 Nov 2017 11:24:50 +0300 Subject: [PATCH] IGNITE-5731: curWaitingJobs and avgJobWaitTime calculation fixed --- .../org/apache/ignite/internal/ClusterMetricsSnapshot.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java b/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java index 8a0bc5ef63bb2..ad1539f7af707 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java @@ -347,7 +347,7 @@ public ClusterMetricsSnapshot(ClusterGroup p) { maxRejectedJobs = max(maxRejectedJobs, m.getCurrentRejectedJobs()); avgRejectedJobs += m.getCurrentRejectedJobs(); - curWaitingJobs += m.getCurrentJobWaitTime(); + curWaitingJobs += m.getCurrentWaitingJobs(); maxWaitingJobs = max(maxWaitingJobs, m.getCurrentWaitingJobs()); avgWaitingJobs += m.getCurrentWaitingJobs(); @@ -357,7 +357,7 @@ public ClusterMetricsSnapshot(ClusterGroup p) { curJobWaitTime = min(curJobWaitTime, m.getCurrentJobWaitTime()); maxJobWaitTime = max(maxJobWaitTime, m.getCurrentJobWaitTime()); - avgJobWaitTime += m.getCurrentJobWaitTime(); + avgJobWaitTime += m.getAverageJobWaitTime(); daemonThreadCnt += m.getCurrentDaemonThreadCount();