hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ndimi...@apache.org
Subject git commit: HBASE-12356 Rpc with region replica does not propagate tracing spans
Date Tue, 28 Oct 2014 17:28:54 GMT
Repository: hbase
Updated Branches:
  refs/heads/master f2f21000f -> bb81b9fde


HBASE-12356 Rpc with region replica does not propagate tracing spans


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/bb81b9fd
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/bb81b9fd
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/bb81b9fd

Branch: refs/heads/master
Commit: bb81b9fde5cea55f226cdba4c98cbc00833f4dea
Parents: f2f2100
Author: Nick Dimiduk <ndimiduk@apache.org>
Authored: Mon Oct 27 16:47:52 2014 -0700
Committer: Nick Dimiduk <ndimiduk@apache.org>
Committed: Tue Oct 28 10:27:59 2014 -0700

----------------------------------------------------------------------
 .../hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/bb81b9fd/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java
index 16c1ac0..85704ff 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java
@@ -51,6 +51,7 @@ import org.apache.hadoop.hbase.protobuf.generated.ClientProtos;
 import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;
 
 import com.google.protobuf.ServiceException;
+import org.htrace.Trace;
 
 /**
  * Caller that goes to replica if the primary region does no answer within a configurable
@@ -413,7 +414,7 @@ public class RpcRetryingCallerWithReadReplicas {
 
     public void submit(ReplicaRegionServerCallable task, int callTimeout) {
       QueueingFuture newFuture = new QueueingFuture(task, callTimeout);
-      executor.execute(newFuture);
+      executor.execute(Trace.wrap(newFuture));
       tasks[task.id] = newFuture;
     }
 


Mime
View raw message