You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by mm...@apache.org on 2017/05/03 17:31:08 UTC
accumulo git commit: ACCUMULO-4365: Configured ConditionalWriterIT
tracer span min to 0
Repository: accumulo
Updated Branches:
refs/heads/1.7 1061fb553 -> b4ed93854
ACCUMULO-4365: Configured ConditionalWriterIT tracer span min to 0
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b4ed9385
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b4ed9385
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b4ed9385
Branch: refs/heads/1.7
Commit: b4ed93854aa28a1152f80a5f38e5efec247f2d9a
Parents: 1061fb5
Author: Mike Miller <mm...@apache.org>
Authored: Wed May 3 12:59:45 2017 -0400
Committer: Mike Miller <mm...@apache.org>
Committed: Wed May 3 12:59:45 2017 -0400
----------------------------------------------------------------------
.../org/apache/accumulo/test/ConditionalWriterIT.java | 12 ++++++++++++
1 file changed, 12 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4ed9385/test/src/test/java/org/apache/accumulo/test/ConditionalWriterIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/ConditionalWriterIT.java b/test/src/test/java/org/apache/accumulo/test/ConditionalWriterIT.java
index 87f813a..d66b472 100644
--- a/test/src/test/java/org/apache/accumulo/test/ConditionalWriterIT.java
+++ b/test/src/test/java/org/apache/accumulo/test/ConditionalWriterIT.java
@@ -63,6 +63,7 @@ import org.apache.accumulo.core.client.TableNotFoundException;
import org.apache.accumulo.core.client.TableOfflineException;
import org.apache.accumulo.core.client.admin.NewTableConfiguration;
import org.apache.accumulo.core.client.security.tokens.PasswordToken;
+import org.apache.accumulo.core.conf.Property;
import org.apache.accumulo.core.data.ArrayByteSequence;
import org.apache.accumulo.core.data.ByteSequence;
import org.apache.accumulo.core.data.Condition;
@@ -90,11 +91,13 @@ import org.apache.accumulo.core.util.UtilWaitThread;
import org.apache.accumulo.examples.simple.constraints.AlphaNumKeyConstraint;
import org.apache.accumulo.harness.AccumuloClusterIT;
import org.apache.accumulo.minicluster.impl.MiniAccumuloClusterImpl;
+import org.apache.accumulo.minicluster.impl.MiniAccumuloConfigImpl;
import org.apache.accumulo.test.functional.BadIterator;
import org.apache.accumulo.test.functional.SlowIterator;
import org.apache.accumulo.tracer.TraceDump;
import org.apache.accumulo.tracer.TraceDump.Printer;
import org.apache.accumulo.tracer.TraceServer;
+import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.Text;
import org.junit.Assert;
import org.junit.Assume;
@@ -116,6 +119,15 @@ public class ConditionalWriterIT extends AccumuloClusterIT {
return 60;
}
+ @Override
+ public void configureMiniCluster(MiniAccumuloConfigImpl cfg, Configuration hadoopCoreSite) {
+ super.configureMiniCluster(cfg, hadoopCoreSite);
+ // Set the min span to 0 so we will definitely get all the traces back. See ACCUMULO-4365
+ Map<String,String> siteConf = cfg.getSiteConfig();
+ siteConf.put(Property.TRACE_SPAN_RECEIVER_PREFIX.getKey() + "tracer.span.min.ms", "0");
+ cfg.setSiteConfig(siteConf);
+ }
+
public static long abs(long l) {
l = Math.abs(l); // abs(Long.MIN_VALUE) == Long.MIN_VALUE...
if (l < 0)