storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [4/8] storm git commit: STORM-3179: Fixing getNimbusSummary in Storm API
Date Fri, 10 Aug 2018 10:28:10 GMT
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 <govindappumenon@gmail.com>
Authored: Tue Aug 7 17:38:23 2018 -0500
Committer: Govind Menon <govindappumenon@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) {


Mime
View raw message