Hi, Ethan Li. Thank you. It worked well. I can see Evenshceduler in storm UI and Nimbus.log.
I have one more question. I want to assign 2GB for each worker. So, I configured a below parameter in storm.yaml. 1. worker.heap.memory.mb However, in "Assigned mem (MB)" in Storm UI, each worker uses 128Mb. Then, I changed a below parameter. 1. topology.component.resources.onheap.memory.mb Then, in "Assigned mem (MB)" in Storm UI, each worker uses 2Gb. However, when I checked "defaults.yaml", "topology.component.resources.onheap.memory.mb" is the value when I use "resource aware scheduler". So, to configure heap memory for each worker, should I use "topology.component.resources.onheap.memory.mb" even though I use "EvenScheduler"? If so, what is "worker.heap.memory.mb" parameter? Thanks in advance. Junguk On Fri, Nov 30, 2018 at 1:33 PM Ethan Li <ethanopensou...@gmail.com> wrote: > > Hi Junguk, > > Please set "storm.scheduler” > (https://github.com/apache/storm/blob/master/storm-server/src/main/java/org/apache/storm/DaemonConfig.java#L96) > to change scheduler > > > - Ethan > > On Nov 30, 2018, at 12:59 PM, Junguk Cho <jman...@gmail.com> wrote: > > Hi, > > I am trying to use "Evenscheduler" in Storm 2.0. > I configured scheduler like this. > topology.scheduler.strategy: "org.apache.storm.scheduler.EvenScheduler" > > However, when I ran Nimbus, it said > Exception in thread "main" java.lang.IllegalArgumentException: Field > VALIDATE_TOPOLOGY_SCHEDULER_STRATEGY with value > org.apache.storm.scheduler.EvenScheduler does not implement > org.apache.storm.scheduler.resource.strategies.scheduling.IStrategy > > Would you please let me know how to configure "EvenScheduler" in Storm 2.0? > > Thanks, > Junguk > >
