Github user revans2 commented on a diff in the pull request: https://github.com/apache/storm/pull/2385#discussion_r149163179 --- Diff: storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java --- @@ -479,6 +499,18 @@ private void addDefaultResforExec(ExecutorDetails exec) { adjustResourcesForExec(exec, defaultResourceList); + Map<String,Double> topologyComponentResourcesMap = ( + Map<String, Double>) this.topologyConf.getOrDefault( + Config.TOPOLOGY_COMPONENT_RESOURCES_MAP, new HashMap<>() + ); + + assert topologyComponentResourcesMap != null; + + //topologyComponentResourcesMap = normalizedResourceMap(topologyComponentResourcesMap); --- End diff -- Not needed please delete.
---