@rdhabalia I am a little confused on how the schedule manager can schedule something before membership manager receives notification that it is the leader. In the scheduleManager, we have a check before invoking actual scheduling:
https://github.com/apache/incubator-pulsar/blob/master/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java#L93 Am I missing something? [ Full content available at: https://github.com/apache/incubator-pulsar/pull/2437 ] This message was relayed via gitbox.apache.org for [email protected]
