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);
}