Repository: hbase Updated Branches: refs/heads/master 7377fcd29 -> e9dae2adc
HBASE-21683 Reset readsEnabled flag after successfully flushing the primary region Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e9dae2ad Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e9dae2ad Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e9dae2ad Branch: refs/heads/master Commit: e9dae2adc381550eb3e2b65be246309b309e7f06 Parents: 7377fcd Author: zhangduo <zhang...@apache.org> Authored: Mon Jan 7 20:09:20 2019 +0800 Committer: Duo Zhang <zhang...@apache.org> Committed: Tue Jan 8 16:06:34 2019 +0800 ---------------------------------------------------------------------- .../hbase/regionserver/handler/RegionReplicaFlushHandler.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/e9dae2ad/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/handler/RegionReplicaFlushHandler.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/handler/RegionReplicaFlushHandler.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/handler/RegionReplicaFlushHandler.java index b917379..81b6d7e 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/handler/RegionReplicaFlushHandler.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/handler/RegionReplicaFlushHandler.java @@ -145,6 +145,7 @@ public class RegionReplicaFlushHandler extends EventHandler { + " of region " + region.getRegionInfo().getEncodedName() + " Now waiting and blocking reads until observing a full flush cycle"); } + region.setReadsEnabled(true); break; } else { if (response.hasWroteFlushWalMarker()) { @@ -156,6 +157,7 @@ public class RegionReplicaFlushHandler extends EventHandler { + " of region " + region.getRegionInfo().getEncodedName() + " Now waiting and " + "blocking reads until observing a flush marker"); } + region.setReadsEnabled(true); break; } else { // somehow we were not able to get the primary to write the flush request. It may be
