Repository: hbase
Updated Branches:
  refs/heads/branch-1 439711e0a -> 5f1691d06


HBASE-17302 The region flush request disappeared from flushQueue - addendum 
(Guangxu Cheng)


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

Branch: refs/heads/branch-1
Commit: 5f1691d06e62be48e107ac16119c588361149aed
Parents: 439711e
Author: tedyu <[email protected]>
Authored: Sat Apr 22 15:09:29 2017 -0700
Committer: tedyu <[email protected]>
Committed: Sat Apr 22 15:09:29 2017 -0700

----------------------------------------------------------------------
 .../org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/5f1691d0/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
----------------------------------------------------------------------
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
index 120724d..9ce61e3 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
@@ -800,8 +800,8 @@ class MemStoreFlusher implements FlushRequester {
         return false;
       }
       FlushRegionEntry other = (FlushRegionEntry) obj;
-      if (!this.region.getRegionInfo().getRegionNameAsString().equals(
-              other.region.getRegionInfo().getRegionNameAsString())) {
+      if (!Bytes.equals(this.region.getRegionInfo().getRegionName(),
+          other.region.getRegionInfo().getRegionName())) {
         return false;
       }
       return compareTo(other) == 0;

Reply via email to