Ethan Li created STORM-2834:
-------------------------------
Summary: getOwnerResourceSummaries not working properly because
scheduler is wrapped as BlacklistScheduler
Key: STORM-2834
URL: https://issues.apache.org/jira/browse/STORM-2834
Project: Apache Storm
Issue Type: Bug
Reporter: Ethan Li
Assignee: Ethan Li
Priority: Minor
https://github.com/apache/storm/blob/master/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java#L4101
{code:java}
if (clusterSchedulerConfig.containsKey(theOwner)) {
if (scheduler instanceof ResourceAwareScheduler) {
Map<String, Object> schedulerConfig = (Map)
clusterSchedulerConfig.get(theOwner);
if (schedulerConfig != null) {
ownerResourceSummary.set_memory_guarantee((double)schedulerConfig.getOrDefault("memory",
0));
ownerResourceSummary.set_cpu_guarantee((double)schedulerConfig.getOrDefault("cpu",
0));
ownerResourceSummary.set_memory_guarantee_remaining(ownerResourceSummary.get_memory_guarantee()
- ownerResourceSummary.get_memory_usage());
ownerResourceSummary.set_cpu_guarantee_remaining(ownerResourceSummary.get_cpu_guarantee()
- ownerResourceSummary.get_cpu_usage());
}
} else if (scheduler instanceof MultitenantScheduler) {
ownerResourceSummary.set_isolated_node_guarantee((int)
clusterSchedulerConfig.getOrDefault(theOwner, 0));
}
}
{code}
Because scheduler is wrapped as BlackListScheduler
(https://github.com/apache/storm/blob/master/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java#L474),
these two "instanceof" will never be true.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
