Index: src/java/org/apache/hadoop/hbase/mapreduce/IndexRecordWriter.java =================================================================== --- src/java/org/apache/hadoop/hbase/mapreduce/IndexRecordWriter.java (revision 789847) +++ src/java/org/apache/hadoop/hbase/mapreduce/IndexRecordWriter.java Tue Aug 25 10:01:32 PDT 2009 @@ -136,9 +136,14 @@ */ @Override public void run() { + try { + context.setStatus("Closing"); + } catch (IOException e) { + return; + } - while (!closed) { + while (!closed) { try { - context.setStatus("closing"); + context.progress(); Thread.sleep(1000); } catch (InterruptedException e) { continue;