This is an automated email from the ASF dual-hosted git repository.

bipinprasad pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git


The following commit(s) were added to refs/heads/master by this push:
     new e21b71b  [STORM-3807] Topology Stats columns show NaN (#3424)
e21b71b is described below

commit e21b71b56353cc4c7ce6d628d44223e3ca32fe80
Author: Bipin Prasad <[email protected]>
AuthorDate: Thu Nov 18 12:17:12 2021 -0500

    [STORM-3807] Topology Stats columns show NaN (#3424)
    
    Co-authored-by: Bipin Prasad <[email protected]>
---
 storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

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 a37f773..eece882 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
@@ -1577,9 +1577,8 @@ public class UIHelpers {
             temp.put("emitted", emittedStatDisplayMap.get(window));
             temp.put("transferred", transferred.get(window));
             temp.put("completeLatency", 
StatsUtil.floatStr(completeLatency.get(getWindowHint(window))));
-            temp.put("acked", acked.get(window));
-            temp.put("failed", failed.get(window));
-
+            temp.put("acked", acked.getOrDefault(window, 0L));
+            temp.put("failed", failed.getOrDefault(window, 0L));
 
             result.add(temp);
         }

Reply via email to