You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2018/08/10 10:28:09 UTC

[3/8] storm git commit: STORM-3181: Fix for completeLatency in TopologyStats

STORM-3181: Fix for completeLatency in TopologyStats


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/66a1aa34
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/66a1aa34
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/66a1aa34

Branch: refs/heads/master
Commit: 66a1aa34141aa6f5b8b04c73935fd140cf47987e
Parents: 73382d9
Author: Govind Menon <go...@gmail.com>
Authored: Tue Aug 7 15:37:56 2018 -0500
Committer: Govind Menon <go...@gmail.com>
Committed: Tue Aug 7 15:37:56 2018 -0500

----------------------------------------------------------------------
 .../src/main/java/org/apache/storm/daemon/ui/UIHelpers.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/66a1aa34/storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java
----------------------------------------------------------------------
diff --git a/storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java b/storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java
index 4096763..9567239 100644
--- a/storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java
+++ b/storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java
@@ -1148,7 +1148,7 @@ public class UIHelpers {
             temp.put("window", window);
             temp.put("emitted", emittedStatDisplayMap.get(window));
             temp.put("transferred", transferred.get(window));
-            temp.put("completeLatency", completeLatency.get(window));
+            temp.put("completeLatency", StatsUtil.floatStr(completeLatency.get(getWindowHint(window))));
             temp.put("acked", acked.get(window));
             temp.put("failed", failed.get(window));