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:10 UTC
[4/8] storm git commit: STORM-3179: Fixing getNimbusSummary in Storm
API
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 <go...@gmail.com>
Authored: Tue Aug 7 17:38:23 2018 -0500
Committer: Govind Menon <go...@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) {