Github user roshannaik commented on a diff in the pull request:
https://github.com/apache/storm/pull/2634#discussion_r182549691
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -3032,9 +3019,19 @@ public void submitTopologyWithOpts(String topoName,
String uploadedJarLocation,
// if the other config does not have it set.
topology = normalizeTopology(totalConf, topology);
- //set the number of acker executors;
- totalConfToSave.put(Config.TOPOLOGY_ACKER_EXECUTORS,
getNumOfAckerExecs(totalConf, topology));
- LOG.debug("Config.TOPOLOGY_ACKER_EXECUTORS set to: {}",
totalConfToSave.get(Config.TOPOLOGY_ACKER_EXECUTORS));
+ // if the Resource Aware Scheduler is used,
+ // we might need to set the number of acker executors and
eventlogger executors to be the estimated number of workers.
+ if (ServerUtils.isRAS(conf)) {
+ int estimatedNumWorker =
ServerUtils.getEstimatedWorkerCountForRASTopo(totalConf, topology);
+ int numAckerExecs =
ObjectReader.getInt(totalConf.get(Config.TOPOLOGY_ACKER_EXECUTORS),
estimatedNumWorker);
+ int numEventLoggerExecs =
ObjectReader.getInt(totalConf.get(Config.TOPOLOGY_EVENTLOGGER_EXECUTORS),
estimatedNumWorker);
+
+ totalConfToSave.put(Config.TOPOLOGY_ACKER_EXECUTORS,
numAckerExecs);
--- End diff --
Is this a case where we are overriding the acker & eventLogger count
settings that are set by user ?
---
