Hi, While running a map-reduce job, that has only mappers, I have a counter that counts the number of failed documents .And after all the mappers are done, I want the job to fail if the total number of failed documents are above a fixed fraction. ( I need it in the end because I don't know the total number of documents initially). How can I achieve this without implementing a reduce just for this ? I know that there are task level cleanup method. But is there any job level cleanup method, that can be used to perform this after all the tasks are done ?
Thanks Abhinav
