diff --git a/accumulo/src/main/java/com/yahoo/ycsb/db/AccumuloClient.java b/accumulo/src/main/java/com/yahoo/ycsb/db/AccumuloClient.java index db78e8793d531b28843a64989dd14f252f5bb107..6886307cda431eaf2d421780a91a25c07f375bb1 100644 --- a/accumulo/src/main/java/com/yahoo/ycsb/db/AccumuloClient.java +++ b/accumulo/src/main/java/com/yahoo/ycsb/db/AccumuloClient.java @@ -169,11 +169,11 @@ public class AccumuloClient extends DB { bwc.setMaxWriteThreads(Integer.parseInt( getProperties().getProperty("accumulo.batchWriterThreads", "1"))); - bw = connector.createBatchWriter(table, bwc); + bw = connector.createBatchWriter(t, bwc); // Create our scanners - singleScanner = connector.createScanner(table, Authorizations.EMPTY); - scanScanner = connector.createScanner(table, Authorizations.EMPTY); + singleScanner = connector.createScanner(t, Authorizations.EMPTY); + scanScanner = connector.createScanner(t, Authorizations.EMPTY); table = t; // Store the name of the table we have open. }