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 2016/12/13 20:45:15 UTC
hbase git commit: HBASE-17302 The region flush request disappeared
from flushQueue (Guangxu Cheng)
Repository: hbase
Updated Branches:
refs/heads/master 233359627 -> de98f6840
HBASE-17302 The region flush request disappeared from flushQueue (Guangxu Cheng)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/de98f684
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/de98f684
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/de98f684
Branch: refs/heads/master
Commit: de98f684086bc33b418d530c2473902a97fbc7cc
Parents: 2333596
Author: tedyu <yu...@gmail.com>
Authored: Tue Dec 13 12:45:09 2016 -0800
Committer: tedyu <yu...@gmail.com>
Committed: Tue Dec 13 12:45:09 2016 -0800
----------------------------------------------------------------------
.../org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/de98f684/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 15cf97c..a123dd5 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
@@ -814,7 +814,11 @@ class MemStoreFlusher implements FlushRequester {
if (obj == null || getClass() != obj.getClass()) {
return false;
}
- Delayed other = (Delayed) obj;
+ FlushRegionEntry other = (FlushRegionEntry) obj;
+ if (!this.region.getRegionInfo().getRegionNameAsString().equals(
+ other.region.getRegionInfo().getRegionNameAsString())) {
+ return false;
+ }
return compareTo(other) == 0;
}
}