You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2019/01/08 09:04:10 UTC
[09/15] hbase git commit: HBASE-21683 Reset readsEnabled flag after
successfully flushing the primary region
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/HBASE-21512
Commit: e9dae2adc381550eb3e2b65be246309b309e7f06
Parents: 7377fcd
Author: zhangduo <zh...@apache.org>
Authored: Mon Jan 7 20:09:20 2019 +0800
Committer: Duo Zhang <zh...@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