diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/DefaultSourceFSConfigurationProvider.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/DefaultSourceFSConfigurationProvider.java index 8a4d331..0f0d81c 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/DefaultSourceFSConfigurationProvider.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/DefaultSourceFSConfigurationProvider.java @@ -61,7 +61,8 @@ public class DefaultSourceFSConfigurationProvider implements SourceFSConfigurati } LOG.info("Loading source cluster " + replicationClusterId - + " file system configurations from xml files under directory " + replicationConfDir); + + " file system configurations from xml files under directory " + + replicationConfDir + "/" + replicationClusterId); File confDir = new File(replicationConfDir, replicationClusterId); String[] listofConfFiles = FileUtil.list(confDir); for (String confFile : listofConfFiles) {