hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bus...@apache.org
Subject hbase git commit: HBASE-13978: Variable never assigned in SimpleTotalOrderPartitioner.getPartition()
Date Wed, 01 Jul 2015 18:29:26 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.2 580495d30 -> ce5f25c7c


HBASE-13978: Variable never assigned in SimpleTotalOrderPartitioner.getPartition()

Signed-off-by: Sean Busbey <busbey@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ce5f25c7
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ce5f25c7
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ce5f25c7

Branch: refs/heads/branch-1.2
Commit: ce5f25c7c49caaf89f788bd42eb1b9e2c559eab1
Parents: 580495d
Author: Bhupendra <bhupendra.jain@huawei.com>
Authored: Mon Jun 29 14:40:07 2015 +0530
Committer: Sean Busbey <busbey@apache.org>
Committed: Wed Jul 1 13:24:56 2015 -0500

----------------------------------------------------------------------
 .../hadoop/hbase/mapreduce/SimpleTotalOrderPartitioner.java       | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/ce5f25c7/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 1c65068..4cc7a8a 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(), Bytes.BYTES_RAWCOMPARATOR);
@@ -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;
   }
 }


Mime
View raw message