This question has been asked before, but I tried suggested solutions such as call Context.setStatus() or progress(), neither them helped. Please advise.
My reduce task is doing some CPU extensive work in reduce task, below is my code snippet @Override protected void reduce(Text inpput, Iterable<LongWritable> docsIDs, Context context) throws IOException, InterruptedException { // really quick operation } @Override protected void cleanup(Context context) throws IOException, InterruptedException { // massive work here for(....){ //doing one iteration context.setStatus("Iteration #"+i); context.progress(); } } -- --Anfernee