You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2014/05/23 00:37:46 UTC
[2/3] git commit: ACCUMULO-378 Better logging to whom the master is
connecting
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 <el...@apache.org>
Authored: Thu May 22 18:32:53 2014 -0400
Committer: Josh Elser <el...@apache.org>
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(),