hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From la...@apache.org
Subject git commit: HBASE-11225 Backport fix for HBASE-10417 index is not incremented in PutSortReducer#reduce() (Gustavo Anatoly)
Date Thu, 22 May 2014 18:45:28 GMT
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 <larsh@apache.org>
Authored: Thu May 22 11:44:51 2014 -0700
Committer: Lars Hofhansl <larsh@apache.org>
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);
       }
 


Mime
View raw message