accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [1/3] accumulo git commit: ACCUMULO-4191 Wrapped runnable with Trace.wrap in TabletServerBatchWriter to prevent loss of sendMutation events
Date Sun, 17 Apr 2016 17:45:06 GMT
Repository: accumulo
Updated Branches:
  refs/heads/1.7 18caa5b17 -> e77bdd7de
  refs/heads/master d1cb53b16 -> c43c7be6b


ACCUMULO-4191 Wrapped runnable with Trace.wrap in TabletServerBatchWriter to prevent loss
of sendMutation events

Closes apache/accumulo#94

Signed-off-by: Josh Elser <elserj@apache.org>


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

Branch: refs/heads/1.7
Commit: e77bdd7de25af87c53da6e5a3727c028956c1e00
Parents: 18caa5b
Author: Shawn Walker <accumulo@shawn-walker.net>
Authored: Fri Apr 15 10:38:37 2016 -0400
Committer: Josh Elser <elserj@apache.org>
Committed: Sun Apr 17 13:44:36 2016 -0400

----------------------------------------------------------------------
 .../accumulo/core/client/impl/TabletServerBatchWriter.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/e77bdd7d/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
b/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
index 77d8307..a8afa5a 100644
--- a/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
+++ b/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
@@ -735,7 +735,7 @@ public class TabletServerBatchWriter {
     void queueMutations(final MutationSet mutationsToSend) throws InterruptedException {
       if (null == mutationsToSend)
         return;
-      binningThreadPool.execute(new Runnable() {
+      binningThreadPool.execute(Trace.wrap(new Runnable() {
 
         @Override
         public void run() {
@@ -748,7 +748,7 @@ public class TabletServerBatchWriter {
             }
           }
         }
-      });
+      }));
     }
 
     private void addMutations(MutationSet mutationsToSend) {


Mime
View raw message