Changeset [5265fd639f82f369a1f3f798305abdc815f6687c] by Shayan Pooya
May 8th, 2014 @ 09:17 AM
job_coordinator: Make sure a stage has finished before sending an event.
In the old model, the do_stage_done function is called only when
a stage
finishes and there is no need for double checks. However, in the
concurrent
model, this function might be called when some tasks are finished.
Disco has to
make sure this stage can be finished before actually finishing
it.
https://github.com/discoproject/disco/commit/5265fd639f82f369a1f3f7...
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.