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..7a44073 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 @@ -60,8 +60,13 @@ public class DefaultSourceFSConfigurationProvider implements SourceFSConfigurati } } + String separatorChar = "/"; + if (replicationConfDir.endsWith(separatorChar)) { + separatorChar = ""; + } LOG.info("Loading source cluster " + replicationClusterId - + " file system configurations from xml files under directory " + replicationConfDir); + + " file system configurations from xml files under directory " + + replicationConfDir + separatorChar + replicationClusterId); File confDir = new File(replicationConfDir, replicationClusterId); String[] listofConfFiles = FileUtil.list(confDir); for (String confFile : listofConfFiles) {