From e029c554bb70162b69c0992b93cbae581c7c7409 Mon Sep 17 00:00:00 2001 From: tedyu Date: Tue, 13 Dec 2016 12:46:42 -0800 Subject: [PATCH] HBASE-17302 The region flush request disappeared from flushQueue (Guangxu Cheng) --- .../apache/hadoop/hbase/regionserver/MemStoreFlusher.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 6c2dfb21ffa..3465805a51f 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; } }