accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ctubb...@apache.org
Subject [1/7] accumulo git commit: ACCUMULO-4365: Configured ConditionalWriterIT tracer span min to 0
Date Wed, 03 May 2017 20:38:56 GMT
Repository: accumulo
Updated Branches:
  refs/heads/1.8 6e9f1f728 -> cae07900b
  refs/heads/master f453f4d9c -> ac460d0c8


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.8
Commit: b4ed93854aa28a1152f80a5f38e5efec247f2d9a
Parents: 1061fb5
Author: Mike Miller <mmiller@apache.org>
Authored: Wed May 3 12:59:45 2017 -0400
Committer: Mike Miller <mmiller@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)


Mime
View raw message