HBASE-21683 Reset readsEnabled flag after successfully flushing the primary region
This commit is contained in:
parent
3de116af46
commit
1c73b230b8
|
@ -145,6 +145,7 @@ public class RegionReplicaFlushHandler extends EventHandler {
|
||||||
+ " of region " + region.getRegionInfo().getEncodedName()
|
+ " of region " + region.getRegionInfo().getEncodedName()
|
||||||
+ " Now waiting and blocking reads until observing a full flush cycle");
|
+ " Now waiting and blocking reads until observing a full flush cycle");
|
||||||
}
|
}
|
||||||
|
region.setReadsEnabled(true);
|
||||||
break;
|
break;
|
||||||
} else {
|
} else {
|
||||||
if (response.hasWroteFlushWalMarker()) {
|
if (response.hasWroteFlushWalMarker()) {
|
||||||
|
@ -156,6 +157,7 @@ public class RegionReplicaFlushHandler extends EventHandler {
|
||||||
+ " of region " + region.getRegionInfo().getEncodedName() + " Now waiting and "
|
+ " of region " + region.getRegionInfo().getEncodedName() + " Now waiting and "
|
||||||
+ "blocking reads until observing a flush marker");
|
+ "blocking reads until observing a flush marker");
|
||||||
}
|
}
|
||||||
|
region.setReadsEnabled(true);
|
||||||
break;
|
break;
|
||||||
} else {
|
} else {
|
||||||
// somehow we were not able to get the primary to write the flush request. It may be
|
// somehow we were not able to get the primary to write the flush request. It may be
|
||||||
|
|
Loading…
Reference in New Issue