You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2016/04/17 19:45:06 UTC
[1/3] accumulo git commit: ACCUMULO-4191 Wrapped runnable with
Trace.wrap in TabletServerBatchWriter to prevent loss of sendMutation events
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 <el...@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 <ac...@shawn-walker.net>
Authored: Fri Apr 15 10:38:37 2016 -0400
Committer: Josh Elser <el...@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) {
[3/3] accumulo git commit: Merge branch '1.7'
Posted by el...@apache.org.
Merge branch '1.7'
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/c43c7be6
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/c43c7be6
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/c43c7be6
Branch: refs/heads/master
Commit: c43c7be6b6aa6ca7c50b73ceebf7f6c9ff97bee7
Parents: d1cb53b e77bdd7
Author: Josh Elser <el...@apache.org>
Authored: Sun Apr 17 13:44:54 2016 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Sun Apr 17 13:44:54 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/c43c7be6/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
----------------------------------------------------------------------
[2/3] accumulo git commit: ACCUMULO-4191 Wrapped runnable with
Trace.wrap in TabletServerBatchWriter to prevent loss of sendMutation events
Posted by el...@apache.org.
ACCUMULO-4191 Wrapped runnable with Trace.wrap in TabletServerBatchWriter to prevent loss of sendMutation events
Closes apache/accumulo#94
Signed-off-by: Josh Elser <el...@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/master
Commit: e77bdd7de25af87c53da6e5a3727c028956c1e00
Parents: 18caa5b
Author: Shawn Walker <ac...@shawn-walker.net>
Authored: Fri Apr 15 10:38:37 2016 -0400
Committer: Josh Elser <el...@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) {