Hi, I have a use case where I want to pass a threshold value to a map-reduce job. For eg: error records=10.
I want map-reduce job to fail if total count of error_records in the job i.e. all mappers, is reached. How can I implement this considering that each mapper would be processing some part of the input data ? Thanks, -JJ