Github user kishorvpatil commented on a diff in the pull request:
https://github.com/apache/storm/pull/2902#discussion_r231580524
--- Diff:
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java ---
@@ -691,8 +691,10 @@ public static boolean isRAS(Map<String, Object> conf) {
public static int getEstimatedWorkerCountForRASTopo(Map<String,
Object> topoConf, StormTopology topology)
throws InvalidTopologyException {
- return (int)
Math.ceil(getEstimatedTotalHeapMemoryRequiredByTopo(topoConf, topology) /
-
ObjectReader.getDouble(topoConf.get(Config.WORKER_HEAP_MEMORY_MB)));
+ Double defaultWorkerMaxHeap =
ObjectReader.getDouble(topoConf.get(Config.WORKER_HEAP_MEMORY_MB));
+ Double topologyWorkerMaxHeap =
ObjectReader.getDouble(topoConf.get(Config.TOPOLOGY_WORKER_MAX_HEAP_SIZE_MB));
--- End diff --
There is default of this value -
https://github.com/apache/storm/blob/master/conf/defaults.yaml#L332 and
https://github.com/apache/storm/blob/master/conf/defaults.yaml#L332 avoids it.
But we can
So I don't anticipate that happening, but I am adding defaults.
---
