Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2358#discussion_r143374458
--- Diff:
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java ---
@@ -934,7 +942,7 @@ public void setStatusMap(Map<String, String> statusMap)
{
public Map<String, SupervisorResources> getSupervisorsResourcesMap() {
Map<String, SupervisorResources> ret = new HashMap<>();
for (SupervisorDetails sd : supervisors.values()) {
- ret.put(sd.getId(), new
SupervisorResources(sd.getTotalMemory(), sd.getTotalMemory(), 0, 0));
+ ret.put(sd.getId(), new
SupervisorResources(sd.getTotalMemory(), sd.getTotalCPU(), 0, 0));
--- End diff --
Nice catch.
---