Repository: accumulo Updated Branches: refs/heads/master 5002d162e -> f453f4d9c
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/master Commit: 6e9f1f728eaf369e2d2ac696f7bfe6d465407f1b Parents: 02f24e0 Author: Mike Miller <mmil...@apache.org> Authored: Wed May 3 14:06:09 2017 -0400 Committer: Mike Miller <mmil...@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)
