I'm trying to implement a scheduler (EDF). The scheduler should be able to kill or free-up a running map slot so that it can be assigned as a map slot to another job.
I did some looking around and found a kill() method in org.apache.hadoop.mapred.JobInProgress. But, this kills the entire job. I want the job to still be working after a map slot has been removed from it. Can you guys tell me the right method/class to use? Thanks