HBASE-17302 The region flush request disappeared from flushQueue (Guangxu Cheng)
This commit is contained in:
parent
1f9214bee7
commit
e029c554bb
|
@ -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;
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue