From a984b44798656aa421c93cbd9bbb71b06716437c Mon Sep 17 00:00:00 2001 From: kpalanisamy Date: Thu, 7 Feb 2019 16:29:21 -0800 Subject: [PATCH] HBASE-21816 : Print source cluster replication config directory Signed-off-by: Josh Elser Signed-off-by: Toshihiro Suzuki --- .../regionserver/DefaultSourceFSConfigurationProvider.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 8a4d331aefb..f7040d6fc81 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,9 +60,10 @@ public class DefaultSourceFSConfigurationProvider implements SourceFSConfigurati } } - LOG.info("Loading source cluster " + replicationClusterId - + " file system configurations from xml files under directory " + replicationConfDir); File confDir = new File(replicationConfDir, replicationClusterId); + LOG.info("Loading source cluster " + replicationClusterId + + " file system configurations from xml " + + "files under directory " + confDir); String[] listofConfFiles = FileUtil.list(confDir); for (String confFile : listofConfFiles) { if (new File(confDir, confFile).isFile() && confFile.endsWith(XML)) {