You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by mm...@apache.org on 2018/02/22 18:54:47 UTC
[accumulo-examples] branch master updated: ACCUMULO-4804 Fix
ChunkInput ITs
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 <mm...@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
mmiller@apache.org.