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 (Guangxu Cheng)
Date Tue, 13 Dec 2016 20:45:15 GMT
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 <yuzhihong@gmail.com>
Authored: Tue Dec 13 12:45:09 2016 -0800
Committer: tedyu <yuzhihong@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;
     }
   }


Mime
View raw message