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 <els...@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 <accum...@shawn-walker.net> Authored: Fri Apr 15 10:38:37 2016 -0400 Committer: Josh Elser <els...@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) {
