Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-11212 Fix increment index in KeyValueSortReducer. (Gustavo Anatoly)

This commit is contained in:
Lars Hofhansl 2014-05-22 11:54:30 -07:00
parent 46e53b089a
commit dd9ac0c0ad
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/KeyValueSortReducer.java
View File

@ -51,7 +51,7 @@ public class KeyValueSortReducer extends Reducer<ImmutableBytesWritable, KeyValu
int index = 0; int index = 0;
for (KeyValue kv: map) { for (KeyValue kv: map) {
context.write(row, kv); context.write(row, kv);
if (index > 0 && index % 100 == 0) context.setStatus("Wrote " + index); if (++index % 100 == 0) context.setStatus("Wrote " + index);
} }
} }
} }