Call JobConf.setMaxMapAttempts(0) in the job conf, then throw an exception
when your mapper fails. This should kill the entire job instantly, since
the job tracker will allow no mapper failures.
Cheers,
Anthony
On Mon, Jul 30, 2007 at 09:42:09PM +0100, [EMAIL PROTECTED] wrote:
> Hi,
>
> Apologies for yet another question from me, but here goes!
>
> I've written a map task that will on occasion not compute the correct
> result. This can easily be detected, at which point I'd like the map
> task to report the error and terminate the entire map/reduce job. Does
> anyone know of a way I can do this?
>
> I've been looking around the archives and the api, and the only thing
> that comes close is the reporter class, but I can't I think that only
> reports stuff and doesn't actually allow control of the job?
>
> Any help much appreciated as ever,
>
> Cheers,
> Ollie
>
--
Au
PGP Key ID: 0x385B44CB
Fingerprint: 9E9E B116 DB2C D734 C090 E72F 43A0 95C4 385B 44CB
"Maximus vero fugiens a quodam Urso, milite Romano, interemptus est"
- Getica 235
