STORM-3179: Fixing getNimbusSummary in Storm API
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/bc1078d9 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/bc1078d9 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/bc1078d9 Branch: refs/heads/master Commit: bc1078d9114da5840c133a56ffda5e1d917b023d Parents: 73382d9 Author: Govind Menon <govindappume...@gmail.com> Authored: Tue Aug 7 17:38:23 2018 -0500 Committer: Govind Menon <govindappume...@gmail.com> Committed: Tue Aug 7 17:38:23 2018 -0500 ---------------------------------------------------------------------- .../org/apache/storm/daemon/ui/UIHelpers.java | 26 +++++++++----------- 1 file changed, 12 insertions(+), 14 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/bc1078d9/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..8e88042 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 @@ -1909,21 +1909,19 @@ public class UIHelpers { for (NimbusSummary nimbusSummary : nimbusSummaries) { Map<String, Object> nimbusSummaryMap = new HashMap(); - if (nimbusSeeds.contains(nimbusSummary.get_host() + ":" + String.valueOf(nimbusSummary.get_port()))) { - nimbusSummaryMap.put("host", nimbusSummary.get_host()); - nimbusSummaryMap.put("port", nimbusSummary.get_port()); - String status = "Not a Leader"; - if (nimbusSummary.is_isLeader()) { - status = "Leader"; - } - nimbusSummaryMap.put("status", status); - nimbusSummaryMap.put("version", nimbusSummary.get_version()); - nimbusSummaryMap.put("nimbusUpTimeSeconds", nimbusSummary.get_uptime_secs()); - nimbusSummaryMap.put("nimbusUpTime", prettyUptimeSec(nimbusSummary.get_uptime_secs())); - nimbusSummaryMap.put("nimbusLogLink", getNimbusLogLink(nimbusSummary.get_host(), config)); - resultSummaryList.add(nimbusSummaryMap); - nimbusSeeds.remove(nimbusSummary.get_host() + ":" + String.valueOf(nimbusSummary.get_port())); + nimbusSummaryMap.put("host", nimbusSummary.get_host()); + nimbusSummaryMap.put("port", nimbusSummary.get_port()); + String status = "Not a Leader"; + if (nimbusSummary.is_isLeader()) { + status = "Leader"; } + nimbusSummaryMap.put("status", status); + nimbusSummaryMap.put("version", nimbusSummary.get_version()); + nimbusSummaryMap.put("nimbusUpTimeSeconds", nimbusSummary.get_uptime_secs()); + nimbusSummaryMap.put("nimbusUpTime", prettyUptimeSec(nimbusSummary.get_uptime_secs())); + nimbusSummaryMap.put("nimbusLogLink", getNimbusLogLink(nimbusSummary.get_host(), config)); + resultSummaryList.add(nimbusSummaryMap); + nimbusSeeds.remove(nimbusSummary.get_host() + ":" + String.valueOf(nimbusSummary.get_port())); } for (String nimbusSeed : nimbusSeeds) {