hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-17302 The region flush request disappeared from flushQueue - addendum (Guangxu Cheng)
Date Sun, 23 Apr 2017 14:37:41 GMT
Repository: hbase
Updated Branches:
  refs/heads/master 9053ec6fe -> 435104af7


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/435104af
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/435104af
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/435104af

Branch: refs/heads/master
Commit: 435104af70232076145df4211da297c9235cd58f
Parents: 9053ec6
Author: tedyu <yuzhihong@gmail.com>
Authored: Sun Apr 23 07:37:34 2017 -0700
Committer: tedyu <yuzhihong@gmail.com>
Committed: Sun Apr 23 07:37:34 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/435104af/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 aaa9572..2f2a4cf 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
@@ -816,8 +816,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;


Mime
View raw message