Run Reduce tasks without waiting for faild/killed Map tasks output

[Sultan Alamro <su...@gmail.com>]

Hi,

I am running some experiments where not all Map tasks should be executed,
or continue processing. My application will fail/kill the running Map tasks
if a condition is true. The Reduce tasks should continue processing without
waiting for the output of the failed/killed tasks.

I was able to fail/kill the running Map tasks and let the AM not to recover
these tasks. However, the Reduce tasks keep waiting for the output of the
failed/killed tasks.

The question is, how can I let Reduce tasks continue processing with the
finished Map tasks only?

Thanks,