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.
---