Hi! I had a same case that you have mentioned. What I have done: 1. Create a scheduler class (see the attached file) 2. On the Nimbus node, in the $STORM_HOME/conf/storm.yaml add the following lines storm.scheduler: "NetworkScheduler" supervisor.scheduler.meta: name: "special-supervisor" 3. On the nimbus-node, put the jar file that contains the scheduler class in $STORM_HOME/conf/lib 4. Restart nimbus 5. Pay attention to the code
TopologyDetails topology = topologies.getByName("network");
only the topology having the name ""network" will be scheduled as you want.
This is case sensitive
T
I hope that these help.
On Tue, Jun 2, 2015 at 8:10 PM, B. Candler <[email protected]> wrote:
> On 02/06/2015 17:26, B. Candler wrote:
>
>> However I couldn't find any authoritative documentation on the scheduler
>> API by browsing
>> https://storm.apache.org/doc-index.html
>> (but I might have missed the right link)
>>
> BTW after further digging I did find a couple of lines here:
>
> https://storm.apache.org/2012/08/02/storm080-released.html#pluggable-scheduler
>
> and that lead me to
>
> https://github.com/apache/storm/blob/master/storm-core/src/jvm/backtype/storm/scheduler/IScheduler.java
> (after fixing the link)
>
> Regards,
>
> Brian.
>
>
NetworkScheduler.java
Description: Binary data
