Changeset [5b331662788762c726ef951d702a774437a0e526] by Shayan Pooya
May 8th, 2014 @ 09:02 AM
job_coordinator: Do not start a new stage if there is one started already.
In the make_stage_tasks, when we are creating the next stage, we
normally are
sure that it has not been created. However, in the concurrent model
we cannot
make this assertion. Therefore, we make this function more strict
in this
commit.
https://github.com/discoproject/disco/commit/5b331662788762c726ef95...
Committed by Shayan Pooya
- M master/src/job_coordinator.erl
Create new ticket
Create your profile
Help contribute to this project by taking a few moments to create your personal profile. Create your profile ยป
Disco is an open-source implementation of the Map-Reduce framework for distributed computing. As the original framework, Disco supports parallel computations over large data sets on unreliable cluster of computers.