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.


---

Reply via email to