Author: tedyu
Date: Tue May 20 19:54:17 2014
New Revision: 1596381
URL: http://svn.apache.org/r1596381
Log:
HBASE-10417 index is not incremented in PutSortReducer#reduce() (Gustavo)
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java
URL:
http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java?rev=1596381&r1=1596380&r2=1596381&view=diff
==============================================================================
---
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java
(original)
+++
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java
Tue May 20 19:54:17 2014
@@ -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);
}