ACCUMULO-378 Better logging to whom the master is connecting
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/327b0abc Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/327b0abc Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/327b0abc Branch: refs/heads/ACCUMULO-378 Commit: 327b0abc0dfcdf17422effd2f797fcfc519b6373 Parents: 4288bbe Author: Josh Elser <[email protected]> Authored: Thu May 22 18:32:53 2014 -0400 Committer: Josh Elser <[email protected]> Committed: Thu May 22 18:32:53 2014 -0400 ---------------------------------------------------------------------- .../org/apache/accumulo/core/client/impl/ReplicationClient.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/327b0abc/core/src/main/java/org/apache/accumulo/core/client/impl/ReplicationClient.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/accumulo/core/client/impl/ReplicationClient.java b/core/src/main/java/org/apache/accumulo/core/client/impl/ReplicationClient.java index 6e36759..02ae3d0 100644 --- a/core/src/main/java/org/apache/accumulo/core/client/impl/ReplicationClient.java +++ b/core/src/main/java/org/apache/accumulo/core/client/impl/ReplicationClient.java @@ -83,6 +83,8 @@ public class ReplicationClient { String zkPath = ZooUtil.getRoot(instance) + Constants.ZMASTER_REPLICATION_COORDINATOR_ADDR; String replCoordinatorAddr; + log.debug("Using ZooKeeper quorum at {} with path {} to find peer Master information", instance.getZooKeepers(), zkPath); + // Get the coordinator port for the master we're trying to connect to try { ZooReader reader = new ZooReader(instance.getZooKeepers(), instance.getZooKeepersSessionTimeOut()); @@ -95,6 +97,8 @@ public class ReplicationClient { // Throw the hostname and port through HostAndPort to get some normalization HostAndPort coordinatorAddr = HostAndPort.fromString(replCoordinatorAddr); + log.debug("Connecting to master at {}", coordinatorAddr.toString()); + try { // Master requests can take a long time: don't ever time out ReplicationCoordinator.Client client = ThriftUtil.getClientNoTimeout(new ReplicationCoordinator.Client.Factory(), coordinatorAddr.toString(),
