If you want to kill the whole job (I assume that's what you mean by
"aborting all map tasks") from a mapper, you can use:
new JobClient(jobConf).getJob(job.get("mapred.job.id")).killJob();
- milind
On 4/16/08 10:25 AM, "Owen O'Malley" <[EMAIL PROTECTED]> wrote:
> On Apr 16, 2008, at 8:28 AM, Chaman Singh Verma wrote:
>
>> I am developing one application with MapReduce and in that whenever
>> some
>> MapTask condition is
>> met, I would like to broadcast to all other MapTask to abort their
>> work. I
>> am not quite sure whether
>> such broadcasting functionality currently exist in Hadoop
>> MapReduce. Could
>> someone give some
>> hints.
>
> This is pretty atypical behavior, but you could have each map look
> for the existence of an hdfs file every 1 minute or so. When the
> condition is true, create the file and your maps will exit in the
> next minute. Except on very large clusters, that wouldn't be too
> expensive...
>
> -- Owen
- Milind
--
Milind Bhandarkar, Chief Spammer, Grid Team
Y!IM: GridSolutions
408-349-2136
([EMAIL PROTECTED])
