I need some help regarding Apache Storm 1.0.3 with Resource Aware Scheduler Enabled. I have a storm cluster with 2 supervisors. Each supervisor has 20 slots, 8000 CPU and 100GB memory. I submitted my first topology and it went to supervisor 1. Let say it uses 2 slots, 1000 CPU and 2 GB memory. Now i am submitting another topology with same usage. This topology should go to supervisor 2 as it has more available resources compared to supervisor 1 but what actually happened is that the new topology went to supervisor 1.
Same with the 3rd topology. All the topology is going to 1st supervisor unless it is exhausted of slots,CPU or memory. Is this behavior expected? or am i missing something in configurations. Version : 1.0.3 Storm.yaml ========== storm.scheduler: “org.apache.storm.scheduler.resource.ResourceAwareScheduler” supervisor.memory.capacity.mb: 100000.0 supervisor.cpu.capacity: 8000.0 topology.component.resources.onheap.memory.mb: 10.2 topology.component.resources.offheap.memory.mb: 10.2 topology.component.cpu.pcore.percent: 10.00 topology.worker.max.heap.size.mb: 2048.0 topology.priority: 29 topology.scheduler.strategy: “org.apache.storm.scheduler.resource.strategies.scheduling.DefaultResourceAwareStrategy” resource.aware.scheduler.eviction.strategy: “org.apache.storm.scheduler.resource.strategies.eviction.DefaultEvictionStrategy” resource.aware.scheduler.priority.strategy: “org.apache.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy”
