This is an automated email from the ASF dual-hosted git repository. mmiller pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/accumulo-examples.git
The following commit(s) were added to refs/heads/master by this push: new 5b37ccf ACCUMULO-4804 Fix ChunkInput ITs 5b37ccf is described below commit 5b37ccf0929e254b275ea80730f0f1db8ec6c60f Author: Mike Miller <mmil...@apache.org> AuthorDate: Thu Feb 22 13:51:03 2018 -0500 ACCUMULO-4804 Fix ChunkInput ITs --- .../org/apache/accumulo/examples/filedata/ChunkInputFormatIT.java | 6 ++++++ .../org/apache/accumulo/examples/filedata/ChunkInputStreamIT.java | 7 +++++++ 2 files changed, 13 insertions(+) diff --git a/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputFormatIT.java b/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputFormatIT.java index aa56c1b..5ed7d5d 100644 --- a/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputFormatIT.java +++ b/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputFormatIT.java @@ -32,12 +32,14 @@ import java.util.Map.Entry; import org.apache.accumulo.core.client.BatchWriter; import org.apache.accumulo.core.client.BatchWriterConfig; import org.apache.accumulo.core.client.Connector; +import org.apache.accumulo.core.conf.Property; import org.apache.accumulo.core.data.Key; import org.apache.accumulo.core.data.Mutation; import org.apache.accumulo.core.data.Value; import org.apache.accumulo.core.security.Authorizations; import org.apache.accumulo.core.security.ColumnVisibility; import org.apache.accumulo.harness.AccumuloClusterHarness; +import org.apache.accumulo.minicluster.impl.MiniAccumuloConfigImpl; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configured; import org.apache.hadoop.mapreduce.Job; @@ -53,6 +55,10 @@ import com.google.common.collect.ArrayListMultimap; import com.google.common.collect.Multimap; public class ChunkInputFormatIT extends AccumuloClusterHarness { + @Override + public void configureMiniCluster(MiniAccumuloConfigImpl cfg, Configuration hadoopCoreSite) { + cfg.setProperty(Property.TSERV_NATIVEMAP_ENABLED, "false"); + } // track errors in the map reduce job; jobs insert a dummy error for the map and cleanup tasks (to ensure test correctness), // so error tests should check to see if there is at least one error (could be more depending on the test) rather than zero diff --git a/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputStreamIT.java b/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputStreamIT.java index 69b8f48..e45762a 100644 --- a/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputStreamIT.java +++ b/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputStreamIT.java @@ -33,6 +33,7 @@ import org.apache.accumulo.core.client.Connector; import org.apache.accumulo.core.client.Scanner; import org.apache.accumulo.core.client.TableExistsException; import org.apache.accumulo.core.client.TableNotFoundException; +import org.apache.accumulo.core.conf.Property; import org.apache.accumulo.core.data.Key; import org.apache.accumulo.core.data.KeyValue; import org.apache.accumulo.core.data.Mutation; @@ -41,11 +42,17 @@ import org.apache.accumulo.core.security.Authorizations; import org.apache.accumulo.core.security.ColumnVisibility; import org.apache.accumulo.core.util.PeekingIterator; import org.apache.accumulo.harness.AccumuloClusterHarness; +import org.apache.accumulo.minicluster.impl.MiniAccumuloConfigImpl; +import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.io.Text; import org.junit.Before; import org.junit.Test; public class ChunkInputStreamIT extends AccumuloClusterHarness { + @Override + public void configureMiniCluster(MiniAccumuloConfigImpl cfg, Configuration hadoopCoreSite) { + cfg.setProperty(Property.TSERV_NATIVEMAP_ENABLED, "false"); + } private static final Authorizations AUTHS = new Authorizations("A", "B", "C", "D"); -- To stop receiving notification emails like this one, please contact mmil...@apache.org.