Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2385#discussion_r147236953
--- Diff:
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java ---
@@ -993,6 +1054,31 @@ public WorkerResources getWorkerResources(WorkerSlot
ws) {
}
@Override
+ public Map<String, Double> getAllScheduledResourcesForNode(String
nodeId) {
+ Map<String, Double> totalScheduledResources = new HashMap<>();
+ for (SchedulerAssignmentImpl assignment : assignments.values()) {
+ for (Entry<WorkerSlot, WorkerResources> entry :
+ assignment.getScheduledResources().entrySet()) {
+ if (nodeId.equals(entry.getKey().getNodeId())) {
+ WorkerResources resources = entry.getValue();
+ for (Map.Entry resourceEntry :
resources.get_resources().entrySet()) {
--- End diff --
Could you please add in the types for the Map.Entry?
---
