You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by mw...@apache.org on 2019/03/27 20:01:54 UTC
[accumulo-examples] branch master updated: Fix integration tests
(#40)
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 <mw...@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);
}