Hi, I want to launch multiple tasks on multiple machines (t >> m) that can run simultaneously. Currently, I find that every machine processes the tasks in a serial fashion one after another.
I have written a framework with a scheduler and a executor. The scheduler launches a task list on a bunch of machines (that show up as offers). When I send a task list to run with driver->launchTasks(offers[i].id(), tasks[i]) I find that every machine picks up one task at a time (and then goes to the next). This happens even though the offer can accommodate more than one task from this task list easily. Is there something that I am missing? Thanks, Asim
