hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jeffr...@apache.org
Subject hbase git commit: HBASE-13077 BoundedCompletionService doesn't pass trace info to server
Date Tue, 24 Feb 2015 19:59:29 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1.0 f27f1af3c -> 5ea26e56c


HBASE-13077 BoundedCompletionService doesn't pass trace info to server


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

Branch: refs/heads/branch-1.0
Commit: 5ea26e56c5f685d5266e27a096b1983abd65ae80
Parents: f27f1af
Author: Jeffrey Zhong <jeffreyz@apache.org>
Authored: Tue Feb 24 11:54:58 2015 -0800
Committer: Jeffrey Zhong <jeffreyz@apache.org>
Committed: Tue Feb 24 11:54:58 2015 -0800

----------------------------------------------------------------------
 .../org/apache/hadoop/hbase/util/BoundedCompletionService.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/5ea26e56/hbase-common/src/main/java/org/apache/hadoop/hbase/util/BoundedCompletionService.java
----------------------------------------------------------------------
diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/BoundedCompletionService.java
b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/BoundedCompletionService.java
index c3fa547..25ced62 100644
--- a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/BoundedCompletionService.java
+++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/BoundedCompletionService.java
@@ -31,6 +31,7 @@ import java.util.concurrent.FutureTask;
 import java.util.concurrent.TimeUnit;
 
 import org.apache.hadoop.hbase.classification.InterfaceAudience;
+import org.apache.htrace.Trace;
 
 /**
  * A completion service, close to the one available in the JDK 1.7
@@ -65,7 +66,7 @@ public class BoundedCompletionService<V> {
 
   public Future<V> submit(Callable<V> task) {
     QueueingFuture newFuture = new QueueingFuture(task);
-    executor.execute(newFuture);
+    executor.execute(Trace.wrap(newFuture));
     tasks.add(newFuture);
     return newFuture;
   }


Mime
View raw message