You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2017/04/22 22:09:37 UTC
hbase git commit: HBASE-17302 The region flush request disappeared
from flushQueue - addendum (Guangxu Cheng)
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 <yu...@gmail.com>
Authored: Sat Apr 22 15:09:29 2017 -0700
Committer: tedyu <yu...@gmail.com>
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;