Repository: hbase Updated Branches: refs/heads/0.94 71d197c15 -> c9c01e6eb
HBASE-11225 Backport fix for HBASE-10417 index is not incremented in PutSortReducer#reduce() (Gustavo Anatoly) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/c9c01e6e Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c9c01e6e Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c9c01e6e Branch: refs/heads/0.94 Commit: c9c01e6eb12451bf3eb4a0044fd3f496c9c1974f Parents: 71d197c Author: Lars Hofhansl <[email protected]> Authored: Thu May 22 11:44:51 2014 -0700 Committer: Lars Hofhansl <[email protected]> Committed: Thu May 22 11:44:51 2014 -0700 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/c9c01e6e/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java b/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java index e76df8c..da621af 100644 --- a/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java +++ b/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java @@ -70,7 +70,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); }
