diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java index ad58e0c..be11bb0 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java @@ -76,7 +76,7 @@ public class PutSortReducer extends int index = 0; for (KeyValue kv : map) { context.write(row, kv); - if (index > 0 && index % 100 == 0) + if (++index % 100 == 0) context.setStatus("Wrote " + index); }