Github user kayousterhout commented on the pull request:
https://github.com/apache/spark/pull/214#issuecomment-38612977
freeCores would need to be updated by the makeOffers() method and before
the tasks get serialized (otherwise we can have race conditions where we
assign the same core to multiple tasks). I don't think the thread that
serializes and launches tasks needs to access any internal state of the
CGSB, so I don't think this is an issue.
On Tue, Mar 25, 2014 at 12:57 PM, Mridul Muralidharan <
[email protected]> wrote:
> @kayousterhout <https://github.com/kayousterhout> the backend assumes
> that there is only a single thread which is executing inside the actor at
a
> given point of time. We will be changing this assumption.
> For example, updating freeCores (and other manipulations of freeCores/etc
> when responses come into the actor).
> This change will mean we will need to break that implicit assumption.
>
> --
> Reply to this email directly or view it on
GitHub<https://github.com/apache/spark/pull/214#issuecomment-38612685>
> .
>
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
