> In the scheduleManager, we have a check before invoking actual scheduling:
yes, exactly [SchedulerManager](https://github.com/apache/incubator-pulsar/blob/master/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java#L93) tries to schedule only if it is a leader and at that time MemberShipManager has not received that notification of leader so, schedulerManager skips scheduling and RuntimeManager reads last available assignment. I am able to reproduce it in standalone function worker where standalone-scheduler-manager skips scheduling as it finds `isLeader()` false. [ Full content available at: https://github.com/apache/incubator-pulsar/pull/2437 ] This message was relayed via gitbox.apache.org for [email protected]
