diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index bad3890..8b09d7d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -856,6 +856,7 @@ public class HRegionServer extends HasThread implements onlyMetaRefresh, this, this); } registerConfigurationObservers(); + this.walFactory = setupWALAndReplication(); } private void registerConfigurationObservers() { @@ -1347,7 +1348,6 @@ public class HRegionServer extends HasThread implements ZNodeClearer.writeMyEphemeralNodeOnDisk(getMyEphemeralNodePath()); this.cacheConfig = new CacheConfig(conf); - this.walFactory = setupWALAndReplication(); // Init in here rather than in constructor after thread name has been set this.metricsRegionServer = new MetricsRegionServer(new MetricsRegionServerWrapperImpl(this)); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index bf67e91..bbb6f5b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java @@ -1536,6 +1536,7 @@ public class RSRpcServices implements HBaseRPCErrorHandler, WarmupRegionResponse response = WarmupRegionResponse.getDefaultInstance(); try { + checkOpen(); String encodedName = region.getEncodedName(); byte[] encodedNameBytes = region.getEncodedNameAsBytes(); final Region onlineRegion = regionServer.getFromOnlineRegions(encodedName);