Yes schedule is called regularly. It is called with a 10 second sleep in between by default. There are ways to change this, but it is really only for testing. We want to be sure that if a supervisor crashes that things can be rescheduled in a timely manor.
- Bobby On Tuesday, July 4, 2017, 11:59:59 PM CDT, anshu shukla <[email protected]> wrote: Nimbus calls the scheduler after every timeout time. I have an implementation of the custom scheduler that reads the mapping from JSON file and enacts the mapping. In the case of rebalancing with updated mapping, it will enact the new mapping. On Tue, Jul 4, 2017 at 10:25 PM, preethini v <[email protected]> wrote: Hi, I have a question about Storm Default Scheduler. The schedule() function is called when the topology is submitted to the Storm cluster for the first time. I assume that once the schedule() is called, it is called again only during rebalance (ie, if we add more worker nodes) Does Storm call the schedule() again periodically for better reassignments when there is no rebalance or any change to the cluster? Thanks,Preethini -- Thanks & Regards, Anshu Shukla
