You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by bu...@apache.org on 2015/07/01 20:20:44 UTC
hbase git commit: HBASE-13978: Variable never assigned in
SimpleTotalOrderPartitioner.getPartition()
Repository: hbase
Updated Branches:
refs/heads/master 364205da2 -> 7a6f269c4
HBASE-13978: Variable never assigned in SimpleTotalOrderPartitioner.getPartition()
Signed-off-by: Sean Busbey <bu...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/7a6f269c
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/7a6f269c
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/7a6f269c
Branch: refs/heads/master
Commit: 7a6f269c4dfb6143f430f42239d10eafb5bff777
Parents: 364205d
Author: Bhupendra <bh...@huawei.com>
Authored: Mon Jun 29 14:40:07 2015 +0530
Committer: Sean Busbey <bu...@apache.org>
Committed: Wed Jul 1 13:03:21 2015 -0500
----------------------------------------------------------------------
.../hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/7a6f269c/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java
index 52bc8df..fe967ff 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java
@@ -106,6 +106,7 @@ implements Configurable {
for (int i = 0; i < splits.length; i++) {
LOG.info(Bytes.toStringBinary(splits[i]));
}
+ this.lastReduces = reduces;
}
int pos = Bytes.binarySearch(this.splits, key.get(), key.getOffset(),
key.getLength());
@@ -138,5 +139,7 @@ implements Configurable {
}
LOG.info("startkey=" + Bytes.toStringBinary(startkey) +
", endkey=" + Bytes.toStringBinary(endkey));
+ // Reset last reduces count on change of Start / End key
+ this.lastReduces = -1;
}
}