From ffc7215a506f149af70929f18b880a066ea99f16 Mon Sep 17 00:00:00 2001 From: Zhihong Yu Date: Tue, 20 May 2014 19:54:17 +0000 Subject: [PATCH] HBASE-10417 index is not incremented in PutSortReducer#reduce() (Gustavo) git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1596381 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java index ad58e0c071f..be11bb01335 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java +++ b/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); }