This is an automated email from the ASF dual-hosted git repository. mwalch 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 310c1da Fix integration tests (#40) 310c1da is described below commit 310c1da6cf086adf18eb318badb25de2e6e4f641 Author: Mike Walch <mwa...@apache.org> AuthorDate: Wed Mar 27 16:01:50 2019 -0400 Fix integration tests (#40) --- src/test/java/org/apache/accumulo/examples/ExamplesIT.java | 3 ++- .../java/org/apache/accumulo/examples/filedata/ChunkInputFormatIT.java | 3 ++- .../java/org/apache/accumulo/examples/filedata/ChunkInputStreamIT.java | 3 ++- 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/src/test/java/org/apache/accumulo/examples/ExamplesIT.java b/src/test/java/org/apache/accumulo/examples/ExamplesIT.java index 9f713ca..11fcb9c 100644 --- a/src/test/java/org/apache/accumulo/examples/ExamplesIT.java +++ b/src/test/java/org/apache/accumulo/examples/ExamplesIT.java @@ -34,6 +34,7 @@ import java.util.List; import java.util.Map.Entry; import java.util.concurrent.TimeUnit; +import org.apache.accumulo.core.client.Accumulo; import org.apache.accumulo.core.client.AccumuloClient; import org.apache.accumulo.core.client.BatchScanner; import org.apache.accumulo.core.client.BatchWriter; @@ -101,7 +102,7 @@ public class ExamplesIT extends AccumuloClusterHarness { @Before public void setupTest() throws Exception { - c = createAccumuloClient(); + c = Accumulo.newClient().from(getClientProps()).build(); String user = c.whoami(); String instance = getClientInfo().getInstanceName(); String keepers = getClientInfo().getZooKeepers(); 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 23790df..87ca328 100644 --- a/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputFormatIT.java +++ b/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputFormatIT.java @@ -29,6 +29,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Map.Entry; +import org.apache.accumulo.core.client.Accumulo; import org.apache.accumulo.core.client.AccumuloClient; import org.apache.accumulo.core.client.BatchWriter; import org.apache.accumulo.core.client.BatchWriterConfig; @@ -76,7 +77,7 @@ public class ChunkInputFormatIT extends AccumuloClusterHarness { @Before public void setupInstance() throws Exception { - client = createAccumuloClient(); + client = Accumulo.newClient().from(getClientProps()).build(); tableName = getUniqueNames(1)[0]; client.securityOperations().changeUserAuthorizations(client.whoami(), AUTHS); } 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 138867b..cf28d1d 100644 --- a/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputStreamIT.java +++ b/src/test/java/org/apache/accumulo/examples/filedata/ChunkInputStreamIT.java @@ -25,6 +25,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Map.Entry; +import org.apache.accumulo.core.client.Accumulo; import org.apache.accumulo.core.client.AccumuloClient; import org.apache.accumulo.core.client.AccumuloException; import org.apache.accumulo.core.client.AccumuloSecurityException; @@ -68,7 +69,7 @@ public class ChunkInputStreamIT extends AccumuloClusterHarness { @Before public void setupInstance() throws Exception { - client = createAccumuloClient(); + client = Accumulo.newClient().from(getClientProps()).build(); tableName = getUniqueNames(1)[0]; client.securityOperations().changeUserAuthorizations(client.whoami(), AUTHS); }