accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mmil...@apache.org
Subject accumulo git commit: ACCUMULO-4365: Configured ConditionalWriterIT tracer span min to 0
Date Wed, 03 May 2017 18:08:34 GMT
Repository: accumulo
Updated Branches:
  refs/heads/1.8 02f24e066 -> 6e9f1f728


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/6e9f1f72
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/6e9f1f72
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/6e9f1f72

Branch: refs/heads/1.8
Commit: 6e9f1f728eaf369e2d2ac696f7bfe6d465407f1b
Parents: 02f24e0
Author: Mike Miller <mmiller@apache.org>
Authored: Wed May 3 14:06:09 2017 -0400
Committer: Mike Miller <mmiller@apache.org>
Committed: Wed May 3 14:06:09 2017 -0400

----------------------------------------------------------------------
 .../org/apache/accumulo/test/ConditionalWriterIT.java   | 12 ++++++++++++
 1 file changed, 12 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/6e9f1f72/test/src/main/java/org/apache/accumulo/test/ConditionalWriterIT.java
----------------------------------------------------------------------
diff --git a/test/src/main/java/org/apache/accumulo/test/ConditionalWriterIT.java b/test/src/main/java/org/apache/accumulo/test/ConditionalWriterIT.java
index f0b46b5..9ebb2bd 100644
--- a/test/src/main/java/org/apache/accumulo/test/ConditionalWriterIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/ConditionalWriterIT.java
@@ -64,6 +64,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.FastFormat;
 import org.apache.accumulo.examples.simple.constraints.AlphaNumKeyConstraint;
 import org.apache.accumulo.harness.AccumuloClusterHarness;
 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 AccumuloClusterHarness {
     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)


Mime
View raw message