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:46:48 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 1f9214bee -> e029c554b


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

Branch: refs/heads/branch-1
Commit: e029c554bb70162b69c0992b93cbae581c7c7409
Parents: 1f9214b
Author: tedyu <yuzhihong@gmail.com>
Authored: Tue Dec 13 12:46:42 2016 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Tue Dec 13 12:46:42 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/e029c554/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 6c2dfb2..3465805 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
@@ -795,7 +795,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