ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ag...@apache.org
Subject ignite git commit: IGNITE-5731: curWaitingJobs and avgJobWaitTime calculation fixed
Date Mon, 11 Dec 2017 13:21:56 GMT
Repository: ignite
Updated Branches:
  refs/heads/master d4233dcf1 -> 321ba6063


IGNITE-5731: curWaitingJobs and avgJobWaitTime calculation fixed

Signed-off-by: Andrey Gura <agura@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/321ba606
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/321ba606
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/321ba606

Branch: refs/heads/master
Commit: 321ba6063306ec1271258b47dd0236a1f07a3e77
Parents: d4233dc
Author: Denis Loginov <da.loginov@jet.msk.su>
Authored: Mon Dec 11 16:16:07 2017 +0300
Committer: Andrey Gura <agura@apache.org>
Committed: Mon Dec 11 16:16:07 2017 +0300

----------------------------------------------------------------------
 .../java/org/apache/ignite/internal/ClusterMetricsSnapshot.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/321ba606/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java
----------------------------------------------------------------------
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 5f29167..60f26a3 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
@@ -353,7 +353,7 @@ public class ClusterMetricsSnapshot implements ClusterMetrics {
             maxRejectedJobs = max(maxRejectedJobs, m.getCurrentRejectedJobs());
             avgRejectedJobs += m.getCurrentRejectedJobs();
 
-            curWaitingJobs += m.getCurrentJobWaitTime();
+            curWaitingJobs += m.getCurrentWaitingJobs();
             maxWaitingJobs = max(maxWaitingJobs, m.getCurrentWaitingJobs());
             avgWaitingJobs += m.getCurrentWaitingJobs();
 
@@ -363,7 +363,7 @@ public class ClusterMetricsSnapshot implements ClusterMetrics {
 
             curJobWaitTime = min(curJobWaitTime, m.getCurrentJobWaitTime());
             maxJobWaitTime = max(maxJobWaitTime, m.getCurrentJobWaitTime());
-            avgJobWaitTime += m.getCurrentJobWaitTime();
+            avgJobWaitTime += m.getAverageJobWaitTime();
 
             daemonThreadCnt += m.getCurrentDaemonThreadCount();
 


Mime
View raw message