ACCUMULO-769 Fix bsp contrib build due to mapreduce changes in previous commit
git-svn-id: https://svn.apache.org/repos/asf/accumulo/contrib/bsp/trunk@1437074 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormatIT.java b/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormatIT.java
index cf6435e..8dd3f7e 100644
--- a/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormatIT.java
+++ b/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormatIT.java
@@ -20,6 +20,7 @@
import static org.junit.Assert.fail;
import java.io.IOException;
+import java.nio.charset.Charset;
import org.apache.accumulo.bsp.AccumuloInputFormat;
import org.apache.accumulo.bsp.MapreduceWrapper;
@@ -30,7 +31,6 @@
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.hadoop.fs.Path;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.io.Writable;
@@ -97,7 +97,8 @@
bspJob.setBspClass(InputFormatTestBSP.class);
bspJob.setInputPath(new Path("test"));
- AccumuloInputFormat.setInputInfo(job, "root", "".getBytes(), "testtable", new Authorizations());
+ AccumuloInputFormat.setConnectorInfo(job, "root", "".getBytes(Charset.forName("UTF-8")));
+ AccumuloInputFormat.setInputTableName(job, "testtable");
AccumuloInputFormat.setMockInstance(job, "testmapinstance");
AccumuloInputFormat input = new AccumuloInputFormat();
diff --git a/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloOutputFormatIT.java b/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloOutputFormatIT.java
index 3eac515..474487d 100644
--- a/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloOutputFormatIT.java
+++ b/src/test/java/org/apache/accumulo/core/client/mapreduce/AccumuloOutputFormatIT.java
@@ -22,6 +22,7 @@
import static org.junit.Assert.fail;
import java.io.IOException;
+import java.nio.charset.Charset;
import java.util.Iterator;
import java.util.Map.Entry;
@@ -124,9 +125,11 @@
Job job = MapreduceWrapper.wrappedJob(bspJob);
- AccumuloInputFormat.setInputInfo(job, "root", "".getBytes(), "testtable1", new Authorizations());
+ AccumuloInputFormat.setConnectorInfo(job, "root", "".getBytes(Charset.forName("UTF-8")));
+ AccumuloInputFormat.setInputTableName(job, "testtable1");
AccumuloInputFormat.setMockInstance(job, "testmrinstance");
- AccumuloOutputFormat.setOutputInfo(job, "root", "".getBytes(), false, "testtable2");
+ AccumuloOutputFormat.setConnectorInfo(job, "root", "".getBytes(Charset.forName("UTF-8")));
+ AccumuloOutputFormat.setDefaultTableName(job, "testtable2");
AccumuloOutputFormat.setMockInstance(job, "testmrinstance");
AccumuloInputFormat input = new AccumuloInputFormat();
