You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by nd...@apache.org on 2014/10/28 18:28:54 UTC
git commit: HBASE-12356 Rpc with region replica does not propagate
tracing spans
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 <nd...@apache.org>
Authored: Mon Oct 27 16:47:52 2014 -0700
Committer: Nick Dimiduk <nd...@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;
}