Github user Ethanlm commented on a diff in the pull request: https://github.com/apache/storm/pull/2623#discussion_r179772853 --- Diff: storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/BaseResourceAwareStrategy.java --- @@ -477,45 +414,136 @@ protected String nodeToRack(RAS_Node node) { List<ExecutorDetails> execsScheduled = new LinkedList<>(); Map<String, Queue<ExecutorDetails>> compToExecsToSchedule = new HashMap<>(); - for (Component component : componentMap.values()) { - compToExecsToSchedule.put(component.getId(), new LinkedList<ExecutorDetails>()); + for (Map.Entry<String, Component> componentEntry: componentMap.entrySet()) { + Component component = componentEntry.getValue(); + compToExecsToSchedule.put(component.getId(), new LinkedList<>()); for (ExecutorDetails exec : component.getExecs()) { if (unassignedExecutors.contains(exec)) { compToExecsToSchedule.get(component.getId()).add(exec); + LOG.info("{} has unscheduled executor {}", component.getId(), exec); --- End diff -- Will remove it before merging. Wanted to keep this for debugging for now.
---