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 bcbc78b27b..2d3939c5a8 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 @@ -3031,6 +3031,10 @@ public class HRegionServer extends HasThread implements private static T newReplicationInstance(String classname, Class xface, Configuration conf, HRegionServer server, FileSystem walFs, Path logDir, Path oldLogDir, WALProvider walProvider) throws IOException { + if (StringUtils.isBlank(classname)) { + LOG.info("Replication is disabled for {}", xface.getSimpleName()); + return null; + } Class clazz = null; try { ClassLoader classLoader = Thread.currentThread().getContextClassLoader(); @@ -3045,7 +3049,7 @@ public class HRegionServer extends HasThread implements public Map getWalGroupsReplicationStatus(){ Map walGroupsReplicationStatus = new TreeMap<>(); - if(!this.isOnline()){ + if (!this.isOnline() || replicationSourceHandler == null) { return walGroupsReplicationStatus; } List allSources = new ArrayList<>();