You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by sy...@apache.org on 2016/01/22 23:20:01 UTC
[07/13] hbase git commit: HBASE-15139 Connection manager doesn't pass
client metrics to RpcClient
HBASE-15139 Connection manager doesn't pass client metrics to RpcClient
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4bf6f837
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4bf6f837
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4bf6f837
Branch: refs/heads/hbase-12439
Commit: 4bf6f8379d7f85413b914dddf607d016780d40ce
Parents: bd99067
Author: Mikhail Antonov <an...@apache.org>
Authored: Wed Jan 20 14:05:12 2016 -0800
Committer: Mikhail Antonov <an...@apache.org>
Committed: Wed Jan 20 14:17:01 2016 -0800
----------------------------------------------------------------------
.../org/apache/hadoop/hbase/client/ConnectionImplementation.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/4bf6f837/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
index ecac792..d730287 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java
@@ -240,7 +240,7 @@ class ConnectionImplementation implements ClusterConnection, Closeable {
this.registry = setupRegistry();
retrieveClusterId();
- this.rpcClient = RpcClientFactory.createClient(this.conf, this.clusterId);
+ this.rpcClient = RpcClientFactory.createClient(this.conf, this.clusterId, this.metrics);
// Do we publish the status?
if (shouldListen) {