Multiple threads within the mapper where you have the main thread starting a timeout thread and a process thread. Take the result of the thread that finishes first, ignoring the other and killing it all within the Mapper.map() method? Sure it seems possible. (you output from the time out thread is a NOOP...)
Sent from a remote device. Please excuse any typos... Mike Segel On Apr 18, 2012, at 7:39 AM, Ondřej Klimpera <klimp...@fit.cvut.cz> wrote: > Hello, I'd like to ask you if there is a possibility of setting a timeout for > processing one input line of text input in mapper function. > > The idea is, that if processing of one line is too long, Hadoop will cut this > process and continue processing next input line. > > Thank you for your answer. > > Ondrej Klimpera >
