You are viewing a plain text version of this content. The canonical link for it is here.

Posted to devnull@infra.apache.org by "jerrypeng (GitHub)" <gi...@apache.org> on 2018/08/24 00:11:12 UTC

[GitHub] [incubator-pulsar] jerrypeng commented on issue #2437: Race condition function-runtime-manager read old assignments

@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 devnull@infra.apache.org