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